使用示例 https://www.cnblogs.com/ding2016/p/8283796.html
安装参考:
https://blog.csdn.net/zht245648124/article/details/89430328
1、
下载 : wget http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.12-2.3.0.tgz
vim config/server.properties
broker.id=0 【注释: 每台机器不一样 ,0,1,2】
追加 选项
delete.topic.enable=true
log.dirs=/home/hadoop/kafka-212-230/logs/kafka-logs
zookeeper.connect=192.168.91.112:2181,192.168.91.113:2181,192.168.91.114:2181
listeners = PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://192.168.91.112:9092 【注释: 每台机器不一样】
##################################################################
先启动zk
zookeeper-3.4.14/bin/zkServer.sh start 日志会在启动目录下 生成 zookeeper.out
查看状态命令
zookeeper-3.4.14/bin/zkServer.sh status
启动 kafka
bin/kafka-server-start.sh config/server.properties
查看状态命令
zookeeper-3.4.14/bin/zkServer.sh status
创建topic
bin/kafka-topics.sh --create --bootstrap-server 192.168.91.112:9092 --replication-factor 2 --partitions 2 --topic topic_test1
查看主题列表
bin/kafka-topics.sh --list --bootstrap-server 192.168.91.112:9092
启动控制台生产者
bin/kafka-console-producer.sh --broker-list 192.168.100.112:9092 --topic topic_test1
启动控制台消费者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.91.113:9092 --topic topic_test1 --from-beginning
在生产者控制台输入hello world