Kafka常用命令

启动命令

启动kafka很简单,配置好前置的操作后,先进入zookeeper的目录下,启动zookeeper

启动后结果如下所示,就代表命令执行成功了:

PS:因为kafka是需要注册在zookeeper上面,通过zookeeper进行管理和调度的,所以启动kafka之前,我们必须要启动zookeeper。

随后我们进入Kafka目录下,启动kafka,具体操作命令如下所示:

看到没有报错之后kafka就是已经成功被运行了,当然可以jps -lm查看一下,操作命令如下:

可以看到zookeeper和kafka都已经运行起来了,当然这个是单机的命令,集群的命令后面再讲。 
这样启动又一个坏处,就是kafka启动完毕之后,不能关闭终端,为此,我们可以运行这条命令:

运行结果:

多个kafka的话,在各个虚拟机上运行kafka启动命令多次即可。

创建Topic

创建Topic命令如下所示: 
创建一个test的Topic

多集群创建,执行这个需要搭建多机器的kafka集群环境,zkq1/zkq2/zkq3分别代表了3台zookeeper集群的三台机器

 

查看Topic

创建完成后我们需要查看Topic到底是否创建成功了,可以执行如下命令:

同理,zookeeper集群的话,写集群的三台机器的地址即可。 
操作的步骤如下所示,大家一看便知:

Topic消费情况

删除Topic

删除Topic其实页很简单,执行命令如下:

当然,如果你的server.properties内没有配置相关的配置的话,会出现如下错误:

这边是说,你的Topic已经被标记为待删除的Topic,但是呢,你配置文件的开关没有打开,所以只是给它添加了一个标记,实际上,这个Topic并没有被删除。只有,你打开开关之后,会自动删除被标记删除的Topic。

解决办法: 
设置server.properties文件内的“delete.topic.enable=true”,并且重启Kafka就可以了。

参考: 
kafka删除的操作

发送和消费数据

发送数据

消费数据

 

其他操作

其他操作参考其他博客内容

  1. 迁移kafka数据
  2. kafka常用命令总结
  3. Kafka命令行常用命令说明

 

 

 

参考链接:

https://blog.csdn.net/u010416101/article/details/53905593

 

 

 

 

 

Leave a Reply

Your email address will not be published.