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