我的kafka读取数据是java代码实现的，我怎么观察kafka通道数据量

在Java中监控Kafka通道的数据量，你可以通过使用Apache Kafka提供的`KafkaConsumer`或`AdminClient`接口，它们提供了丰富的API来管理和监控消息。以下是几个步骤：

1. **使用KafkaConsumer**:
- 创建`KafkaConsumer`实例时，你可以设置`MetricsReporter`来收集指标，包括消息吞吐量（produced和consumed messages per second）等。这需要添加对应的依赖库，例如`kafka-clients`。

   Properties props = new Properties();
   props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
   props.put(ConsumerConfig.GROUP_ID_CONFIG, "your_group_id");
   props.put(ConsumerConfig.METRICS_RECORDING_LEVEL_CONFIG, MetricsRecordingLevel.INFO.name());
   KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

2. **使用AdminClient**:
- 使用`AdminClient`可以在生产者、消费者级别获取信息，比如获取topic的当前偏移量、消费速率等。

   AdminClient adminClient = AdminClient.create(props);
   TopicDescription topicDesc = adminClient.describeTopics(Collections.singletonList("your_topic")).get().values().iterator().next();
   long consumedBytes = topicDesc.consumerStats().getAndRemove().get(0).getTotalBytesRead();

3. **定期检查并记录**:
- 定期调用上述方法，你可以创建定时任务或者在应用运行周期内执行，然后将数据量存储到数据库或日志文件中以便后续分析。

4. **可视化工具**:
- 另外，还可以使用Kafka的命令行工具`kafka-topics.sh --describe`或者第三方可视化工具如Kafka Connect、Kibana等查看实时或历史的数据流量情况。

相关问题：
1. 如何从Java代码中直接获取单个Topic的实时消费速率？
2. `MetricsRecordingLevel.INFO`对应的具体有哪些监控指标？
3. 如何将收集到的消息量数据持久化存储？