PROSAGA码农传奇-Kafka-Spring Kafka Consumer

Spring Kafka Consumer - 打印Kafka Lag Info

作者: 庸人自扰1
发布时间: 2024-04-18 02:25:54 (6天前)
转自：

<div class =“post-text”itemprop =“text”>
  <P>
    有一个命令行工具......
  </p>
   <pre>
    <code>
      $ kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group myGroup

TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG        CONSUMER-ID                                       HOST                           CLIENT-ID
myTopic                        0          66              66              0          -

</code>
  </pre>
  <P>
    的<strong>
      编辑
    </强>
  </p>
  <P>
    您可以运行命令行工具并捕获输出...
  </p>
   <pre>
    <code>
      Process process = new ProcessBuilder()
        .command("/usr/local/bin/kafka-consumer-groups", "--bootstrap-server", "localhost:9092",
                "--describe", "--group", "siTestGroup")
        .start();
InputStream inputStream = process.getInputStream();
process.waitFor(10, TimeUnit.SECONDS);
ByteArrayOutputStream baos = new ByteArrayOutputStream();
FileCopyUtils.copy(inputStream, baos);
System.out.println(new String(baos.toByteArray()));

</code>
  </pre>
</DIV>