【发布时间】:2019-09-09 17:53:28
【问题描述】:
我是 kafka 的新手,所以我只是在清除我的 kafka 概念。
我创建了一个简单的流式应用程序,它从具有两个分区的单个主题流式传输数据。我有这个应用程序的两个实例(我是在两个项目中基于相同的 application.id 说的)。当我启动应用程序的第三个实例时,我得到了错误。由此,我了解到 kafka 中的 application.id 被视为消费者组 ID,其中单个消费者可以从主题的单个分区中读取,而第三个消费者没有得到任何内容,因此它无法针对该主题进行存储。
我还尝试了另一种情况,在我的一个应用程序中更改了 application.id。因此,通过这样做,应用程序的第三个实例也开始正常工作。所以它证实了我的假设,application.id 被视为消费者组 id。
但我也注意到 group.id, client.id 也存在在那里,这让我感到困惑。在我们的项目中使用 group.id、client.id 的目的是什么,这些属性是什么以及它们是如何工作的。我为所有三个应用程序设置了相同的组 ID。
【问题讨论】:
-
检查 Kafka Reference 怎么样? kafka.apache.org/10/documentation/streams/developer-guide/…
标签: apache-kafka apache-kafka-streams