Kafka如何消费一个平行的话题
我看了Kafka的文件，还不知道如何消费一个话题平行？
假设：我有一个像“发生了一些事情”这样的话题（不要拆分这个话题），我有很多想消费它的客户。那么该怎么办，让多个客户并行消费呢？我应该使用分区和客户群吗？
共有1个答案
使用分区是一种能够并行化主题消费的方法。假设您的主题有10个分区，那么您可以在同一个消费者组中有10个消费者阅读一个分区。如果您的使用者少于分区，那么它们将负责多个分区。如果您拥有的使用者多于分区，那么就会有使用者无法获得分配给他们的任何分区，并且除了可以替换另一个已经死亡的使用者之外，没有其他事情可做。
-
当一个组中只有一个消费者，并且认为消费者无法在session.time.out内进行轮询时，将触发重新平衡，但是在这种情况下，组中只有一个消费者，现在假设session.time.out是30秒和消费者民意调查后50秒组协调员将识别消费者后50秒，并允许它提交偏移或协调员将断开消费者和没有偏移得到提交，并将重新平衡消费者与新的消费者标识？如果上次提交的偏移量是345678，在下一次轮询中，它处理了
-
我的问题与单个消费者从多个话题消费有关。假设所有主题都加载了1M个记录，一个使用者必须处理这些记录。它将按照什么顺序从主题中读取（我的意思是首先读取哪个主题/分区，等等） Kafka内部资料的任何链接会有帮助吗？
-
本文向大家介绍Kafka 的消费者如何消费数据相关面试题，主要包含被问及Kafka 的消费者如何消费数据时的应答技巧和注意事项，需要的朋友参考一下 消费者每次消费数据的时候，消费者都会记录消费的物理偏移量（offset）的位置 等到下次消费时，他会接着上次位置继续消费
-
我正在使用spring boot构建一个web应用程序，现在我需要接收实时通知。我正计划使用apache kafka作为这方面的消息代理。要求用户具有不同的角色，并且根据角色，他们应该接收其他用户正在执行的操作的通知。 我设置了一个生产者和消费者，作为消费者，我可以接收发布到一个主题的信息，比如说topic1。 我遇到的问题是，我可以让多个用户收听同一个主题，而每个用户都应该得到发布到该主题的消息
-
所以我有一个设计，其中我有多个生产者P1、P2、P3、P4... PN写入单个主题T1，它有32个分区。 另一方面，我在一个消费者组中最多有32个消费者。 我想负载平衡我的消息消耗 阅读文档时，我可以看到3个选项： 1。自己定义分区（缺点是我必须知道最后一条消息发送到哪里，或者为每个生产者定义分区范围P） 2。定义一个密钥并将分区决定权交给Kafka哈希算法（缺点-负载平衡将在运气好的情况下定义）
-
试图理解Kafka中的消费者群体行为。示例4分区可用。在消费者方面，消费者群体控制着4个消费者。在这种情况下，在消费者组中的4个消费者中，只有一个消费者始终收到消息。其他人总是无所事事。可能的原因是什么？ 是否所有分区都保存相同的消息？或者所有分区都有相同的消息？或者我们可以认为分区不是均匀分布的吗？