apache-kafka - 为什么kafka消费者轮询经纪人？

Question

目前正在学习 Kafka 架构，我对消费者为什么要轮询代理感到困惑。为什么消费者不简单地订阅代理并提供一些回调信息并等待代理获取记录？那么当broker拿到相关记录后，查找谁需要知道，查看回调信息来调度消息？这将大大减少网络操作的数量。

标签： apache-kafka

Answer 1

Kafka 可以用作消息传递服务，但它不是唯一可能的用例。您还可以将其视为可以按需读取字节（记录）的远程文件。

此外，如果通知机制按照您的建议以消息代理方式实现，您需要处理慢速消费者。Kafka 将所有控制权留给消费者，让他们以自己的速度消费。