kafka-consumer-groups.sh相当于？

作者: 一生流水
发布时间: 2024-04-18 06:13:13 (1天前)
转自：

2 条回复

0#
回复此人
Jacob | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 我不认为Java客户端中存在等价物;我只是看了那个脚本，它调用了一个scala类 <code> ConsumerGroupCommand </code> 。 </p> <P> 我不熟悉scala，但看起来这个类没有公开内部类（例如， <code> ZkConsumerGroupService </code> ）实现命令，因此看起来它不能从用户应用程序调用。 </p> <P> 看起来它无论如何直接写入stdout，而不是生成带有结果的对象。 </p> <P> 我想你可以运行它并捕获stdout ...... </p> <pre> <code> ConsumerGroupCommand.main(new String[] {"--bootstrap-server", "localhost:9092", "--describe", "--group", "test"}); </code> </pre> <P> 或者，您必须从该类中提取一堆代码。 </p> </DIV>

编辑

登录后才能参与评论