docker ps 查看容器id
docker exec -ti 容器id bash
cd /opt/kafka/bin/
1. 进入任意一个kafka容器/opt/kafka/bin/。建立一个topic
./kafka-topics.sh --create --zookeeper zoo1:2181,zoo2:12181,zoo3:2181 --replication-factor 3 --partitions 1 --topic test
2. 查看创建的topic
./kafka-topics.sh --describe --zookeeper zoo1:2181 --topic test
#zookeeper也可以是任一节点
Topic:test PartitionCount:1 ReplicationFactor:2 Configs:
Topic: test Partition: 0 Leader: 1 Replicas: 1,3 Isr: 1,3
#test分区为为1 复制因子为2
#test的分区为0 Replicas: 1,3 复制的为1,3#
3. 创建发布者
./kafka-console-producer.sh --broker-list kafka1:9092,kafka2:9092,kafka3:9092 --topic test
4. 创建消费者
./kafka-console-consumer.sh --bootstrap-server kafka1:9092 --from-beginning --topic test