Kafka单机版环境搭建及使用教程

转自：https://blog.csdn.net/qq_38980688/article/details/105183167

单机版环境搭建

kafka里自带了一个zookeeper，可以不需要再去下载zookeeper。在启动kafka前，需要先启动zookeeper。

（1）首先去修改config目录下的zookeeper.properties
（2）修改config目录下的server.properties，修改log.dirs和zookeeper.connect。log.dirs是日志存放文件夹，zookeeper.connect是zookeeper连接地址（端口和clientPort保持一致）。

至此，kafka单机版环境已搭建完毕。（如果对里面的参数没修改的话，可不修改，直接用默认的）

 

kafka使用教程
（1）启动kafka自带的zookeeper(加了-daemon，可以让这个进程挂在后台进行，否则会发现是个阻塞进程，只能再开一个终端进行其他操作)
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

（2）启动kafka
bin/kafka-server-start.sh -daemon config/server.properties

（3）创建一个topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test


（4）查看topic列表
bin/kafka-topics.sh -list -zookeeper localhost:2181

（5）创建生产者进程  （9092是默认的broker-list端口）
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

（6）创建消费者进程
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

（7）外网访问 vi config/server.properties
advertised.listeners=PLAINTEXT://121.36.246.106:9092