1 安装 brew
https://www.jianshu.com/p/2b209d74139c
安装目录:
/usr/local/Cellar/kafka/1.1.0
2 运行
修改:1.app登录成功返回ErrorCode,2.不需要返回用户权限菜单
3.启动zookeeper
执行命令: zkServer start
4. 以server.properties的配置,启动kafka
在kafka的bin目录下:
执行命令:./kafka-server-start /usr/local/etc/kafka/server.properties
kafka命令:
https://blog.csdn.net/isea533/article/details/73720066
1 启动produce并输入:
./kafka-console-producer --broker-list localhost:9092 --topic pos_topic
./kafka-console-producer --broker-list localhost:9092 --topic voucher
输入: {"posCode":"84568498","posStatus":1,"lastLoginDate":"2018-06-01 15:30:17","lastLoginUser":"082713700","updateUser":"082713700","updateDate":"2018-06-01 15:30:17"}
注意: --bootstrap-server 必须指定,通常--topic也要指定查看的主题。如果想要从头查看消息,还可以指定--from-beginning参数。一般使用的命令如下。
2 启动cosumer显示所有producer的输入:
./kafka-console-consumer --bootstrap-server localhost:9092 --topic pos_topic
./kafka-console-consumer --bootstrap-server localhost:9092 --topic voucher
注意:其中 --broker-list 和 --topic 是两个必须提供的参数。
3 主题的配置
kafka-configs --zookeeper localhost:2181 --describe --entity-type topics --entity-name pos_topic
4 列出所有主题
kafka-topics --list --zookeeper localhost:2181
5 主题配置
kafka-topics --describe --zookeeper localhost:2181 --topic pos_topic