kafka linuxシステムでの一般的なコマンド


1,  zookeeper   startzk.sh
2,  kafka    start-kafka.sh
2,  kafka      kafka-manager : start-kafka-manager.sh
 
3,     :
kafka-console-producer.sh --broker-list node1:9092 --topic my-kafka-topic    //my-kafka-topic topic   
 
4,     :
kafka-console-consumer.sh --bootstrap-server node1:9092 --topic my-kafka-topic
#       ,                   
 
#             ,    --from-beginning  
kafka-console-consumer.sh --bootstrap-server node01:9092 --from-beginning --topic my-kafka-topic
 
 
5,a.  topic
kafka-topics.sh --create --zookeeper node1:2181 --replication-factor 1 --partitions 1 --topic my-kafka-topic
 
b.  topic  
kafka-topics.sh --list --zookeeper node01:2181
 
c.      topic     ,    describe  
kafka-topics.sh --describe --zookeeper node1:2181 --topic test-topic
 
d.#    topic,     topic   
kafka-topics.sh --describe --zookeeper node1:2181
 
e.  topic
kafka-topics.sh --delete --zookeeper node1:2181 --topic my-kafka-topic