Java API获取非compacted topic总消息数
2021-07-17 22:07
标签:key tst group map tps server only offset @param 目前Kafka并没有提供直接的工具来帮助我们获取某个topic的当前总消息数,需要我们自行写程序来实现。下列代码可以实现这一功能,特此记录一下: Java API获取非compacted topic总消息数 标签:key tst group map tps server only offset @param 原文地址:https://www.cnblogs.com/huxi2b/p/9530072.html/**
* 获取某个topic的当前消息数
* Java 8+ only
*
* @param topic
* @param brokerList
* @return
*/
public static long totalMessageCount(String topic, String brokerList) {
Properties props = new Properties();
props.put("bootstrap.servers", brokerList);
props.put("group.id", "test-group");
props.put("enable.auto.commit", "false");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
try (KafkaConsumer
下一篇:Java 面试题
文章标题:Java API获取非compacted topic总消息数
文章链接:http://soscw.com/index.php/essay/106250.html