前言

收集一些在终端下操作kafka的常用命令。

常用命令

切换到kafka目录进行操作

cd /opt/kafka

创建topic

./bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --partitions 3 --replication-factor 2 --topic test

查看所有的topic

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

查看指定的topic

./bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181 --topic test

查看指定topic详情（分区、备份等）

./bin/kafka-topics.sh --describe --zookeepe 127.0.0.1:2181 --topic test

修改topic的partition

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

往某topic生产消息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

从某topic消费消息

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning #（默认用一个线程消费指定topic的所有分区的数据）

topic 分区扩容 修改为10个分区

bin/kafka-topics.sh --zookeeper localhost:2181 -alter --partitions 10 --topic test1

查询消费组

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list

查看消费者信息

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe test

修改topic日志保留时间(毫秒)

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test --config retention.ms=43200000