在流式架构中，代理充当中介，促进数据生产者和消费者之间的通信。它们在管理数据在系统中流动的过程中扮演着关键角色，确保消息高效地从一个点传递到另一个点。代理接收生产者发送的消息，暂时存储这些消息，并将其路由到适当的消费者。这种解耦使得生产者和消费者能够独立操作，处理不同的工作负载，而不会直接影响彼此的性能。
代理的主要功能之一是提供消息持久性。当生产者发送数据时，代理可以暂时保存这些数据，直到消费者准备好处理它。这在消费者可能较慢甚至离线的情况下尤其重要。例如，在一个电子商务应用中，代理可以存储由应用生成的订单消息，直到订单处理服务可用来处理这些消息。这确保了即使消费者暂时不可用，也不会丢失任何数据，从而增强了系统的可靠性。
此外，代理可以实现消息传递保证，例如“至少一次”或“正好一次”的传递语义。这对于要求高度数据完整性和一致性的应用非常关键。例如，在金融交易系统中，代理可以确保每个交易事务被精确处理一次，防止重复交易或遗漏订单。此外，代理通常还提供消息过滤、负载均衡和监控等功能，使其成为提升性能和可扩展性的整体流式架构中的重要组成部分。