Kafka的安裝和簡單使用

1、kafka安裝
1.下載 解壓
2.配置環境變量
export KAFKA_HOME=/apps/kafka
export PATH=$PATH:$KAFKA_HOME/bin
3.配置文件
配置kafka文件:

二.啓動
1:
啓動zookeeper集羣
zkServer.sh start
2:
啓動kafka集羣:
kafka-server-start.sh /apps/kafka/config/server.properties
3:
建立一個名稱爲test的toptic,並只包含一個partition以及replia(備份區)
kafka-topics.sh --create --zookeeper 192.168.222.140:2181 --replication-factor 1 --partitions 1 --topic test
4:使用命令查看toptic:
kafka-topics.sh --list --zookeeper node4
5:發送消息測試(開啓生產者)
kafka-console-producer.sh --broker-list 192.168.222.140:9092 --topic test
6.開啓消費者
kafka-console-consumer.sh --zookeeper 192.168.222.140:9092 --topic test --from-beginning