版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/hudyang/article/details/80419339
2.1 kafka自带zookeeper启动
2.1.1 启动zookeeper
[root@bogon kafka_2.12-1.1.0]# bin/zookeeper-server-start.sh config/zookeeper.properties
2.1.2 zookeeper启动成功标志
[root@bogon bin]# lsof -i:2181
2.1.3 kafka 日志文件
log,dirs=/usr/local/kafka/kafka-logs
2.1.4 启动 kafka
启动kafka:
[root@bogon kafka_2.12-1.1.0]# bin/kafka-server-start.sh config/server.properties
2.1.4 kafka+zookeeper启动成功
启动后会发现zookeeper先前只绑定域名,后边kafka和zookeeper相互绑定上
2.1.5 producer创建topic
[root@bogon kafka_2.12-1.1.0]# bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test1 --partitions 3 --replication-factor 1
查询创建的test1
[root@bogon kafka_2.12-1.1.0]# bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test1
2.1.6 consumer接受topic
[root@bogon kafka_2.12-1.1.0]# bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1
2.1.7 producer发送topic
[root@bogon kafka_2.12-1.1.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1
2.1.8 consumer接受topic成功
