kafka-server-start脚本通过kafka-run-class脚本调用Kafka类来启动Broker,在调用kafka-run-class脚本之前会进行检测命令行参数、设置log4j配置文件、设置JVM内存参数等操作。#!/bin/bash if [$# -lt 1]; #检查参数个数 then #打印命令用法 echo &quo[...]

为了方便管理和使用，Kafka提供了很多管理脚本，Linux版本的管理脚本存放在$KAFKA_ HOME/bin目录下(在$KAFKA_ HOME/bin/windows 目录下可以找到对应的Windows脚本)。下面先来介绍常用脚本的功能。kafka-server-start脚本:启动Kafka Server。kafka-server-stop脚[...]

只有旧版本的消费者客户端才支持删除群组的操作。删除群组操作将从Zookeeper上移除整个群组，包括所有已保存的偏移量。在执行该操作之前，必须关闭所有的消费者。如果不先执行这一步，可能会导致消费者出现不可预测的行为，因为群组的元数据已经从Zookeeper上移除了。示例:删除消费者群组testgroupkafka-consumer-groups.s[...]

在Kafka里，有两个地方保存着消费者群组的信息。对于旧版本的消费者来说，它们的信息保存在Zookeeper上，对于新版本的消费者来说，它们的信息保存在broker上。kafka-consumer-groups.sh工具可以用于列出上述两种消费者群组。它也可以用于删除消费者群组和偏移量信息，不过这个功能仅限于旧版本的消费者群组(信息保存在Zooke[...]

可以使用主题工具列出集群里的所有主题。每个主题占用一行输出，主题之间没有特定的顺序。例如：列出集群里的所有主题。kafka-topics .sh --zookeeper z001.example.com:2181/kafka-cluster --listmy-topic - marked for deletionother-topic主题工具还能[...]