进入kafka_2.11-2.0.0目录下执行
启动zookeeper,单机版启动kafka自带的zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties 启动kafka bin/kafka-server-start.sh config/server.properties 创建topic bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-1025 查看所有topic bin/kafka-topics.sh --list --zookeeper localhost:2181 查看topic信息 bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test-1025 创建生产者 bin/kafka-console-producer.sh --broker-list zk-master01:9092 --topic test-1025 创建消费者 bin/kafka-console-consumer.sh --bootstrap-server zk-master01:9092 --topic test-1025 --from-beginning