Kafka学习笔记（五）：kafka的常用命令及工具KafkaTool学习

前言

在上一章我们在服务器上成功部署了单节点的kafka。Zookeeper的开放端口配置成了2181，Kafka的端口为 9092。

一、Linux常用命令

以下命令均在进入kafka安装目录下使用。

1. 启动zookeeper

nohup bin/zookeeper-server-start.sh config/zookeeper.properties > /home/sinosoft/log/zookeeper &

2. 启动kafka

nohup bin/kafka-server-start.sh config/server.properties > /home/sinosoft/log/kafka &

3. 查看所有topic

bin/kafka-topics.sh --list --zookeeper localhost:2181

4. 删除topic

bin/kafka-topics.sh --delete --zookeeper 192.168.0.100:2181 --topic  ilearning_train_result

5. 查看某一分组消费情况

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.0.100:9092 --describe --group iTraining_comp-consumer-group1

6. 消费某一topic

bin/kafka-console-consumer.sh --bootstrap-server 192.168.0.100:9092 --topic ilearning_train_result --from-beginning

7. 启动生产客户端

bin/kafka-console-producer.sh --broker-list 192.168.0.100:9092 --topic ilearning_train_result

8. 创建topic

bin/kafka-topics.sh --zookeeper 192.168.0.100:2181 --create --topic ilearning_train_result --partitions 1 --replication-factor 1

二、遇到的问题及解决

问题描述：
Kafka使用命令报错：第 306 行:exec: java: 未找到

原因：
Kafka的默认/usr/bin/java路径与我们实际的$JAVA_HOME/bin/java路径不一致导致的。修改我们的实际路径(太麻烦，而且可能会引起其它配置的变化，设置一个软连接就可以了）

解决方案：
设置软连接

ln -s /usr/java/jdk1.8.0_231/bin/java /usr/bin/java

然后就可以使用了：

三、KafkaTool简单使用

使用命令操作kafka相对来说比较复杂，而且也不是特别方便，不够直观，所以本人下载了kafka的一个可视化工具KafkaTool。
KafkaTool官网下载地址

1、添加集群配置

2、连接后

上图中几个点解释下：

• Brokers:集群服务的节点地址
• Topics：Kafka集群中的所有topic（主题）
• Consumers：消费者组

3、添加删除Topic

4、在topic分区中添加消息

key和message选择Text格式，写入后，点击add，就push上该topic分区中了。

四、导航

Kafka学习笔记（一）：什么是消息队列？什么是Kafka？
Kafka学习笔记（二）：Zookeeper 在 Kafka 中的作用
Kafka学习笔记（三）：Kafka和其他常见消息队列的对比
Kafka学习笔记（四）：在Ubuntu18.04上搭建kafka的环境
Kafka学习笔记（六）：Kafka集成在SpringBoot2.x项目中