kafka常用操作指令

個人パス:/root/training/kafka_2.11-2.3.0 kafkaクラスタを起動する(ZKのクラスタを起動することを前提とする):

[root@bigdata111 kafka_2.11-2.3.0]#bin/kafka-server-start.sh config/server.properties &

kafkaクラスタを閉じるには:

[root@bigdata111 kafka_2.11-2.3.0]#bin/kafka-server-stop.sh config/server.properties &

トピックの作成:

[root@bigdata111 kafka_2.11-2.3.0]#bin/kafka-topics.sh --zookeeper bigdata111:2181 --topic calllog --create --replication-factor 1 --partitions 3

    ：
--topic   topic 
--replication-factor       
--partitions       

トピックの削除:

[root@bigdata111 kafka_2.11-2.3.0]# bin/kafka-topics.sh --bootstrap-server bigdata111:9092 bigdata112:9092 bigdata113:9092 --delete --topic calllog

すべてのトピックをリストします.

[root@bigdata111 kafka_2.11-2.3.0]# bin/kafka-topics.sh --bootstrap-server bigdata111:9092 bigdata112:9092 bigdata113:9092 --list

kafka消費者の起動:

[root@bigdata111 kafka_2.11-2.3.0]# bin/kafka-console-consumer.sh --bootstrap-server bigdata111:9092 --topic calllog --from-beginning

消費者グループの表示:

[root@bigdata111 kafka_2.11-2.3.0]# bin/kafka-consumer-groups.sh --zookeeper bigdata111:2181 --group console-consumer-30191 --describe