Kafka基础——常用命令行操作

Posted luckyhui28

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kafka基础——常用命令行操作相关的知识,希望对你有一定的参考价值。

目录

集群启动

启动zookeeper集群

cd /usr/app/zookeeper/bin
./zkServer.sh start
依次启动。

启动kafka集群

cd /usr/app/kafka
bin/kafka-server-satrt.sh -daemon config/server.properties(隐藏后台启动)
bin/kafka-server-satrt.sh  config/server.properties(带后台启动,无法做其他操作)
依次启动

关闭集群

cd /usr/app/kafka
bin/kafka-server-stop.sh stop
依次关闭

获取当前集群全部主题

kafka目录下
bin/kafka-topics.sh --zookeeper 192.168.25.10:2181 --list

创建主题

bin/kafka-topics.sh --zookeeper 192.168.25.10:2181 --create --replication-factor 3 --partitions 1 --topic topic1
topic --主题名称
partitions --分区数(可多于节点,不推荐)
replication-factory --副本数(不可多于节点,例如有三个broker节点,副本数最多可为三)

删除主题

bin/kafka-topics.sh --zookeeper 192.168.25.10:2181 --delete --topic topic1

查看某个 Topic 的详情

bin/kafka-topics.sh --zookeeper 192.168.25.10:2181 --describe --topic topic1

修改分区数

bin/kafka-topics.sh --zookeeper 192.168.25.10:2181 --alter --topic topic1 --partitions 6

使用自带控制台模拟生产者发送消息

bin/kafka-console-producer.sh --brokerlist 192.168.25.10:9092 --topic topic1

使用自带控制台模拟消费者消费消息

普通消费
bin/kafka-console-consumer.sh --bootstrap-server 192.168.25.10:9092 --topic topic1
从头开始消费
 bin/kafka-console-consumer.sh --bootstrap-server 192.168.25.10:9092 --from-beginning --topic topic1

以上是关于Kafka基础——常用命令行操作的主要内容,如果未能解决你的问题,请参考以下文章

kafka 常用命令行操作(查看主题,生产数据,消费数据)

kafka常用命令行

Kafka快速入门(命令行操作)

Kafka常用命令行总结

一 Kafka介绍及常用命令行

kafka 基础概念命令行操作(查看所有topic创建topic删除topic查看某个Topic的详情修改分区数发送消息消费消息 查看消费者组 更新消费者的偏移位置)