kafka linuxシステムでの一般的なコマンド
4674 ワード
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