441 B
441 B
命令
# 查看topics列表
docker exec -it kafka kafka-topics.sh --list --bootstrap-server localhost:9092
# 创建topics
docker exec -it kafka kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic test-data1
# 旧版本
kafka-topics.sh --list --zookeeper zk-1:2181
kafka-topics.sh --zookeeper zk-1:2181 --create --replication-factor 1 --partitions 3 --topic pro-dmin