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



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

不可以,使用者无法获取生产者的客户端 ID。

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

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

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

不,如果你在消费者端需要它,你必须把它作为键或值的一部分传递。

夫卡的哲学是将生产者和消费者脱钩。主题可以由 0-n 使用者读取,并由 0-n 生产者写入。Kafka通常用于(微(服务边界之间的通信,其中服务不关心谁产生了消息,只关心其内容。

最新更新