安装
下载安装文件 https://kafka.apache.org/downloads
解压缩 tar -zxvf kafka_2.12-2.4.1.tgz
修改配置文件 kafka/conf/server.properties
注意 每个节点broker.id 值唯一
启动
kafka-server-start.sh -daemon kafka/config/server.properties
启动console-producer
kafka-console-producer.sh --broker-list master:9092 --topic test
启动console-consumer
kafka-console-consumer.sh --bootstrap-server slave2:9092 --from-beginning --topic test
