Java查看kafka数据量

Java程序可以通过调用 Kafka 的 Java API 来查看 Kafka 中的数据量，具体步骤如下：

1. 引入 Kafka 的 Java API：

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.serialization.StringDeserializer;

2. 创建 KafkaConsumer 对象并配置相关参数：

Properties props = new Properties();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "<kafka服务器地址:端口号>");
props.put(ConsumerConfig.GROUP_ID_CONFIG, "<消费者组名称>");
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

其中，`<kafka服务器地址:端口号>` 为 Kafka 服务器的地址和端口号，`<消费者组名称>` 为消费者组的名称。

3. 订阅要查看的 topic：

consumer.subscribe(Arrays.asList("<topic名称>"));

其中，`<topic名称>` 为要查看的 topic 的名称。

4. 获取当前 topic 的消费进度信息：

Map<TopicPartition, Long> endOffsets = consumer.endOffsets(consumer.assignment());
long totalDataSize = endOffsets.values().stream().mapToLong(Long::longValue).sum();
System.out.println("Current data size of topic " + "<topic名称>" + " is " + totalDataSize);

执行以上代码后，会输出当前 topic 的数据量。其中，`endOffsets` 对象包含了当前消费者组中每个 partition 的消费进度信息，`totalDataSize` 即为当前 topic 的数据量。

注意：以上代码仅适用于 Kafka 0.10.1.0 及以上版本，如果使用的是更老的版本，需要使用不同的 API。