学习kafka笔记

环境

宿主机windows，在vm里面安装 centos7进行测试学习
配置桥接方式上网具体配置参考

配置完网卡后得到centos里面的本地ip

• ifconfig

安装kafka，参考官网教程即可

kafka需要zookeeper，一起安装即可，安装完需要配置环境变量，参考官网顺利进行。

配置kafka

-进到安装目录 config目录修改server.properties文件

我本机的配置
broker.id=0
port=9092
host.name=192.168.227.100
zookepper.connect=localhost:2181

zookeeper.properties里面可以进行zookeeper的配置

测试kafka

• 启动zookeeper： zkServer.sh start 控制台看到：Starting zookeeper … STARTED代表成功
• 启动kafka：kafka-server-start.sh ../config/server.properties
• 创建主题：bin/kafka-topics.sh --create --zookeeper localhost:2181 -replication-factor 1 --partitions 1 --topic test1 test1是主题名称，其他参数还不明白
• 发布消息：bin/kafka-console-producer.sh --broker-list 192.168.227.100:9092 --topic test1 ip是我centos的地址，为什么localhost一直不行呢，后面topic是上面创建的
• 订阅消息：bin/kafka-console-consumer.sh --bootstrap-server localst:9092 --topic test1 --from-beginning 在另外一个控制台进行，方便接收消息。