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

Xia*_*ang 5 apache-kafka

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

Mic*_*son 5

不,消费者无法获得生产者的客户端 ID。

从 Kaka 文档中,客户端 ID 是:

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

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