kafka 常用命令

一、创建topic：

kafka-topics.sh --create --replication-factor 1 --partitions 3 --zookeeper localhost:2181 --topic wklc-nginx-weixin

二、查看topic list：

kafka-topics.sh --zookeeper 127.0.0.1 --list

三、查看单个topic：

kafka-topics.sh --zookeeper 127.0.0.1 --topic api3-nginx --describe

四、从console消费：

kafka-console-consumer.sh --topic wklc-nginx --zookeeper 127.0.0.1:2181 --from-beginning

五、修改topic partitions：

kafka-topics.sh --zookeeper 127.0.0.1 --topic api3-nginx --alter --partitions 3

六、删除topic：

kafka-topics.sh --delete --zookeeper 127.0.0.1 --topic wklc-nginx

七、修改topic config：

kafka-topics.sh --zookeeper localhost:2181 --create --topic my-topic --partitions 1 --replication-factor 1 --config max.message.bytes=64000 --config flush.messages=1

八、修改topic数据存储时间

./kafka-topics.sh --zookeeper 127.0.0.1:2181 -topic coreservice-tomcat --alter --config retention.ms=21600000