记录工作中常用的一些kafka命令行操作脚本。

1、创建Topic

./kafka-topics.sh --zookeeper localhost:2181 --create --topic test --partitions 1 --replication-factor 1

2、增加分区

./kafka-topics.sh --zookeeper localhost:2181 --alter --topic test --partitions 3

3、列出所有Topic

./kafka-topics.sh --zookeeper localhost:2181 --list

4、查看Topic详情

kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe  --topic test

5、配置Topic过期时间

./kafka-configs.sh --zookeeper localhost:2181 --alter --entity-name test --entity-type topics --add-config retention.ms=86400000
#单位毫秒

6、查看Topic配置信息

./kafka-configs.sh --zookeeper localhost:2181 --describe --entity-name test --entity-type topics

7、设置消费组某个topic到最新进度

./kafka-consumer-groups.sh --bootstrap-server localhost:19092 --group testgroup --reset-offsets --topic test -to-latest --execute

8、设置消费组某个topic指定分区到指定的offset

./kafka-consumer-groups.sh --bootstrap-server localhost:19092 --group testgroup --reset-offsets --topic test:1 -to-offset 2 --execute