文章/答案/技术大牛

发布

社区首页 >问答首页 >最新版本的Kafka到底是如何存储/持久化来自消费者的订阅的？

问最新版本的Kafka到底是如何存储/持久化来自消费者的订阅的？
EN

Stack Overflow用户

提问于 2019-07-04 02:06:49

回答 1查看 26关注 0票数 0

我已经为Kafka的生产者端找到了很好的参考架构细节，但是关于端到端模型的细节很少，比如如何从主题中实际消费消息，如何管理订阅，订阅在哪里持久化(我假设作为组协调器上的主题？)，以及反序列化发生的时间。

有没有人有任何细节来帮助确定代理和消费者之间的详细架构？

发布于 2019-07-04 03:56:13

文档中有很大一部分是关于消费者模型的：https://kafka.apache.org/documentation/#theconsumer

消费者组协议的详细信息可以在这两个会谈中找到：

主题订阅不会持久保存在代理上，而是消费者使用重新平衡协议来共享他们的订阅，并在彼此之间分配分区。

记录是从代理“原始”发送的，消费者负责反序列化数据，因此key.deserializer和value.deserializer是强制性的settings。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/56875763

复制

相似问题

问最新版本的Kafka到底是如何存储/持久化来自消费者的订阅的？EN