Kafka0.8.2.1 common commands

# # kafka launch zookeeper-server startbin/kafka-server-stop.sh nohup bin/kafka-server-start.sh config/server.properties > logs/kafka-server-start.log & # # View the current node status echo stat | nc 127.0.0.1 218 create topic Specify the number of backup partitions bin/kafka-topics.sh-- create-- zookeeper slave1.hadoop:2181-- replication-factor 2-- partitions 4-- topic test-topic# View topicbin/kafka-topics.sh-- zookeeper slave1.hadoop:2181--listbin/kafka-topics.sh-- zookeeper slave2.hadoop:2181-- describebin/kafka-topics.sh-- zookeeper slave3.hadoop:2181-- describe-- topic test-topic# create producerbin/kafka- Console-producer.sh-- broker-list slave3.hadoop:9092-- topic test-topic # create consumer bin/kafka-console-consumer.sh-- zookeeper standby.hadoop:2181-- topic test-topic bin/kafka-console-consumer.sh-- zookeeper standby.hadoop:2181-- topic test-topic-- from-beginning # delete topicbin/kafka-run-class.sh kafka.admin.TopicCommand-- zookeeper slave1.hadoop : 2181-topic test-topic-deletebin/kafka-topics.sh-zookeeper slave2.hadoop:2181-delete-topic test-topic