kafka0.8的kafka-run-class.sh 使用样例

kafka0.8的kafka-run-class.sh是一个用于运行Kafka类的脚本。下面是一个使用样例：

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1

这个命令将打印出“test”主题的所有分区的最新偏移量。其中，“--broker-list”参数指定了Kafka代理的地址和端口，“--topic”参数指定了要查询的主题，“--time”参数指定了要查询的时间戳。

相关问题

kafka kafka-run-class kafka.tools.GetOffsetshell

kafka是一个分布式的流处理平台，它可以处理和存储大规模的实时数据流。kafka-run-class是kafka提供的一个脚本工具，用于在命令行中执行指定的类。kafka.tools.GetOffsetShell是用于获取指定topic在指定时间点的偏移量信息的工具。

具体来说，kafka.tools.GetOffsetShell通过指定topic、时间点和broker列表来获取该topic在指定时间点的偏移量。它的用法类似于以下命令：

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --topic <topic> --time <timestamp> --broker-list <broker-list> --partitions <partitions>

其中，<topic>是要查询的topic名称，<timestamp>是要查询的时间点，<broker-list>是broker的地址列表，<partitions>是要查询的分区编号。该命令会返回指定topic在指定时间点的偏移量信息。

另外，kafka.tools.ConsumerOffsetChecker是kafka提供的另一个工具，用于检查消费者的偏移量信息。它可以通过指定zookeeper连接、消费者组和topic来获取消费者的偏移量信息。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* [kafka监控命令kafka-run-class.sh查看消费了多少条数据](https://blog.csdn.net/m0_37739193/article/details/73849523)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
- *3* [kafka_2.9.2-0.8.2.1.tgz](https://download.csdn.net/download/shy_snow/9372309)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]

kafka-run-class.sh

kafka-run-class.sh是Kafka的一个脚本文件，用于启动Kafka的Java类。它可以通过命令行参数来指定要启动的Java类和相关的参数。该脚本通常用于启动Kafka的服务端或客户端程序。