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