kafka命令行

1、创建topic

./kafka-topics.sh --create --zookeeper 172.17.0.25:2181 --topic test --partitions 1 --replication-factor 1

2、查询topic列表

./kafka-topics.sh --zookeeper 172.17.0.25:2181 --list

3、查询某个topic的详细信息

 ./kafka-topics.sh --zookeeper 172.17.0.25:2181 --describe --topic test

4、创建一个生产者

./kafka-console-producer.sh --broker-list 172.17.0.26:9092 --topic test

5、创建一个消费者

./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic topic-1

6、删除一个topic

./kafka-topics.sh --delete --zookeeper 172.17.0.25 --topic deviceInfo

7、kafka的docker命令

docker run -d -p 2181:2181 --name message-router-zookeeper docker.io/wurstmeister/zookeeper:latest
docker run -d -p 9092:9092 --name message-router-kafka -e KAFKA_ZOOKEEPER_CONNECT=172.17.0.25:2181 -e KAFKA_ADVERTISED_HOST_NAME=message-router-kafka -e KAFKA_BROKER_ID=0 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.109.30.170:9092 -e KAFKA_ADVERTISED_PORT=9092 -e KAFKA_PORT=9092 docker.io/wurstmeister/kafka:1.1.0