/**查consumer group消費(fèi)情況*/
kafka-run-class kafka.admin.ConsumerGroupCommand --group {groupName} --bootstrap-server 127.0.0.1:9092 --describe --new-consumer
/**查看kafka topic列表*/
kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
/**查看kafka特定topic的詳情*/
kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic {topicName} --describe
/**查看consumer group列表*/
kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --list
kafka-consumer-groups.sh --new-consumer --zookeeper 127.0.0.1:2181 --list
/**創(chuàng)建分區(qū)*/
kafka-topics.sh --create -zookeeper 127.0.0.1:2181/kafka --replication-factor 1 --partitions 1 --topic {topicName}
kafka-topics.sh --zookeeper 127.0.0.1:2181/kafka --topic {topicName} --describe
kafka-topics.sh --delete -zookeeper 127.0.0.1:2181/kafka --topic {topicName}
/**擴(kuò)展分區(qū)*/
kafka-topics.sh --alter --topic {topicName} --zookeeper 127.0.0.1:2181 --partitions 6
/**KafkaOffsetMonitor監(jiān)控啟動(dòng)命令*/
nohup? java -Xms512M -Xmx1024M -Xss1024K -cp KafkaOffsetMonitor-assembly-0.4.6-Intranet.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --offsetStorage kafka --kafkaBrokers 127.0.0.1:9092,127.0.0.1:9092,127.0.0.1:9092 --zk 127.0.0.1:2181,127.0.0.1:2181,127.0.0.1:2181 --kafkaSecurityProtocol PLAINTEXT --port 9999 --refresh 10.seconds --retain 2.days >/dev/null 2>&1 &