Linux-使用kafka自带程序操作topic

前言

收集一些在终端下操作 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