安装:
0、JDK(采用了v8,v11未测试)
1、Just download kafka.tar.gz, no need zookeeper
2、tar开
3、修改kafka/config下的server.properties(每服务一个,id及监听端口及Log文件必须各不相同)及zookeeper.properties
4、启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
成功检查:jps(显示QuorumPeerMain);tcp2181 ;
5、启动kafka
bin/kafka-server-start.sh config/server1.properties
bin/kafka-server-start.sh config/server2.properties
成功检查:jps(显示kafka)
说明:开始时想复杂了,下了bitnami的ova包,但也不好用。反而是利用upm平台安装kafka就简单很多,只需要停掉upm进程(有些zookeeper会抢占8080,与upm冲突。如果用kafka安装包自带的zookeeper则不会抢占8080,这样upm不停也可以),按照安装步骤安装即可。
验证测试:生产及消费
将文件内容做为消息,由producer发送给broker:
cat /root/xxx.txt | bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic XXX
消费:
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic XXX
订阅方式同producer一样的参数(可通过screen命令在单终端发送/阅读,由screen返回ctrl-a d)
另:一个好用的kafka客户端 for windows:
恢复初始环境的方法:
参考:
https://kafka.apache.org/ 网站的docs部分很好,命令行命令的解释很详细,包括安装及验证测试
标签:bin,zookeeper,笔记,server,学习,sh,kafka,properties From: https://www.cnblogs.com/peterhu318/p/16927683.html