论如何在没有Kafkatool的情况下存活

众所周知,最近服务器加固的越来越高,导致有些服务器的kafka已经不能在kafkatool上访问,当然不排除是kafkatool有问题,但是无论是哪种情况,Kafka命令的使用已经迫在眉睫,所以总结一下。

kafka的安装

https://downloads.apache.org/kafka/

安装 .tgz版本的,no src.tgz,src代表着source,下载下来的是资源,还需要gradle编译,有点麻烦。

安装完成后启动zookeeper,关于zookeeper,虽然我们有在使用,但是它是什么呢?为什么Kafka要用它?还有什么场景会使用Zk?关于Zk的问题有点多,后面单独开一个章节去学习Zk。

关于所有的脚本都在/bin目录下,我们可以看到命名非常清晰,我们可以直接上手使用。

  1. 启动Zk命令
1
2
// -daemon代表后台运行 后面还可以指定特定的配置文件 如果没有指定就会默认使用 /config/zookeeper.properties
 ./zookeeper-server-start.sh -daemon
  1. 启动kafka
1
2
// 和Zk同样的道理
 ./kafka-server-start.sh -daemon

Kafka的使用

Topic的创建

常用命令

  1. 查询kafka topic列表

./kafka-topics.sh –list –zookeeper localhost: