• 安装配置

修改配置文件：server.properties

配置环境变量 & 分发安装包：xsync kafka/

 

以守护进程模式启动kafka

bin/kafka-server-start.sh -daemon config/server.properties

查看后台进程

jps

看所有集群情况

xcall.sh jps

编写群启脚本：

创建该文件

vi kk.sh

给予权限：

chmod 777 kk.sh

群关：

群启：

• Topic增删查

查看& 创建Topic:

删除Topic & 发送消息：

消费消息 & 查看Topic详情 & 修改分区数

查看详情：

partitioncount :分区

replicationfactor:副本

一个server可以有多个分区，但是只能有一个副本

• 生产者&消费者

生产者(server: hadoop102)指定Topic & 生产消息：

 

消费者(server: hadoop103)订阅Topic & 消费消息：

消费者(server: hadoop104)可以不在线，随时在线，随时获取消息：

kafka在0.9版本之前依赖zk, 0.9之后建议使用bootstrap-server来代替zk：

待更新。。。

参考资料来源: 尚硅谷_Kafka入门