如何使用java在Kafka中检查生产者ID，客户端ID？

Question

我想检查kafka中生产者的id和客户端id。我知道我们无法在消费者中访问它们，所以我在哪里可以找到ID？我可以在发送消息之前得到它们吗？还是它在日志中的某个地方？

Answer 1

您可以找到类似的日志

[Producer clientId=producer-1]

和

[Consumer clientId=test-client-id, groupId=test-id2]

如果您想使用java获取客户端id，请阅读API AdminClient

Map<String, ConsumerGroupDescription> allGroupDetails = client.describeConsumerGroups(allGroups).all().get(10, TimeUnit.SECONDS);

ConsumerGroupDescription->收藏->客户端ID