首页 > 其他分享 >kafka学习笔记

kafka学习笔记

时间:2022-11-26 16:46:47浏览次数:68  
标签:bin zookeeper 笔记 server 学习 sh kafka properties

安装:

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

相关文章