2017-07-18 115 views
0

我在哪里我有两个卡夫卡监听器组件,每个组件听一个不同的主题,并期待不同的有效载荷。 我的问题是,我可以同时使用相同的客户端ID还是它必须有所不同?如果client-id必须有所不同,我想了解可以有效使用client-id的用例。春季卡夫卡消费者客户端配置

回答

0

根据文档:

一个ID字符串提出请求时,传递给服务器。这样做的目的是通过允许将逻辑应用程序名称包含在服务器端请求日志中,从而能够跟踪ip/port之外的请求源。

因此,技术上你真的可以有不同的消费者/生产者

+0

您好,感谢您的答复相同的值。然而,spring-kafka迫使我为两位kafka听众使用不同的client-id,因为它说它必须是唯一的。 –

+0

它在类KafkaListenerEndpointRegistry(Line 152) –

+0

'@ KafkaListener.id()'中抛出一个错误“另一个端点已经用id注册了”?你看到某个地方有一个这个bean id映射到'client-id'的指针吗?你应该直接使用'ConsumerConfig.CLIENT_ID_CONFIG'。 –