gpt4 book ai didi

apache-kafka - kafka中b/w group.id,application.id和client.id有什么区别?

转载 作者:行者123 更新时间:2023-12-03 15:24:30 25 4
gpt4 key购买 nike

我是kafka的新手,所以我只是在清除我的kafka概念。

我创建了一个简单的流应用程序,该应用程序从具有两个分区的单个主题中流数据。我有这个应用程序的两个实例(我在两个项目中都是基于同一个application.id来说这个的)。当我启动应用程序的第三个实例时,出现了错误。据此,我了解到kafka中的application.id被视为消费者组ID,其中单个消费者可以从主题的单个分区读取,而第三个消费者则无法获取任何东西,因此无法针对该主题进行存储。

我还尝试了另一种情况,其中我在一个应用程序中更改了application.id。因此,通过执行此操作,该应用程序的第三个实例也开始正常运行。因此,它证实了我的假设,即application.id被视为消费者组ID。

但是我也注意到group.id,client.id也存在,这使我感到困惑。在我们的项目中使用group.id,client.id的目的是什么,这些属性是什么以及它们如何工作。我为所有三个应用程序都设置了相同的组ID。

最佳答案

简而言之:

  • client.id(用于producerconsumer)设置单个Kafka生产者或消费者客户端的名称。
  • group.id 设置单个Kafka消费者客户端所属的Kafka consumer group的名称。
  • application.id 是仅由Kafka Streams用于命名应用程序(即使用Kafka Streams库的应用程序(可以在1个以上应用程序实例上运行)的应用程序)的设置。在后台,application.id也用于设置group.idclient.id
  • 关于apache-kafka - kafka中b/w group.id,application.id和client.id有什么区别?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57858963/

    25 4 0
    Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
    广告合作:1813099741@qq.com 6ren.com