【发布时间】:2021-07-12 19:03:52
【问题描述】:
将ProducerConfig.CLIENT_ID_CONFIG设置为kafka生产者的真正目的是什么。医生说
发出请求时传递给服务器的 id 字符串。目的 这是为了能够跟踪请求的来源,而不仅仅是 通过允许将逻辑应用程序名称包含在 ip/port 中 服务器端请求日志记录。
默认值:(空)
属性:client.id
因此,生产者似乎将此信息发送到代理/主题/分区。但是,如何在服务器上检索/验证这些信息。 重要的是,消费者能否读取/检索此(client.id)信息并找到消息是由哪个生产者发布的。
当两个生产者有意或无意地使用同一个 client.id 时会发生什么。
【问题讨论】:
标签: java apache-kafka kafka-consumer-api kafka-producer-api