问如何用java检查Kafka中的生产者id，客户id？
EN

Stack Overflow用户

提问于 2021-04-19 00:16:23

回答 1查看 161关注 0票数 0

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

发布于 2021-04-19 17:52:29

你可以找到像这样的日志

[Producer clientId=producer-1]

和

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

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

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

ConsumerGroupDescription ->集合-> clientId

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/67150754

复制

相似问题

问如何用java检查Kafka中的生产者id，客户id？EN