我可以在 kafka 消费者中获取生产者客户端 ID 吗？

Question

在创建 kafka producer 的过程中，我们可以分配一个 client id。它是干什么用的？我可以在消费者中获取生产者客户端 ID 吗？例如，查看哪个生产者产生了消息？

Answer 1

不，消费者无法获取生产者的客户端 ID。

根据 Kaka 文档，client-ids 是：

发出请求时传递给服务器的 id 字符串。目的 这是为了能够跟踪请求的来源，而不仅仅是 通过允许将逻辑应用程序名称包含在 ip/port 中 服务器端请求日志记录。

它们仅用于在代理日志中识别客户端。

Answer 2

不，如果您在消费者方面需要它，您必须将其作为键或值的一部分传递。

Kafka 的理念是将生产者和消费者解耦。一个主题可以被 0-n 个消费者读取并被 0-n 个生产者写入。 Kafka 通常用于（微）服务边界之间的通信，其中服务不关心消息是谁产生的，只关心其内容。