Kafka常用命令

kafka启动：bin/kafka-server-start.sh -daemon config/server.properties
kafka停止：bin/kafka-server-stop.sh
选项说明：
--topic topic名称
--replication-factor 副本数
--partitions 分区数
--zookeeper 本机ip:zk端口号
--bootstrap-list 本机ip:kafka端口号
--broker-list 本机ip:kafka端口号
--from-beginning 查看历史消息

查看当前服务器所有topic

[root@kafka-master kafka]# bin/kafka-topics.sh --zookeeper master:2181 --list

创建topic

[root@kafka-master kafka]# bin/kafka-topics.sh --zookeeper master:2181 --create --topic topicname --partitions 3 --replication-factor 1

删除topic

[root@kafka-master kafka]# bin/kafka-topics.sh --zookeeper master:2181 --delete --topic topicname

修改topic分区数 注意：只能增加，不能减少

[root@kafka-master kafka]# bin/kafka-topics.sh --zookeeper master:2181 --alter --topic topicname --partitions 4

查看topic详情

[root@kafka-master kafka]# bin/kafka-topics.sh --zookeeper master:2181 --describe --topic topicname

生产者发送消息

[root@kafka-master kafka]# bin/kafka-console-producer.sh --broker-list master:9092 --topic topicname

消费者消费消息

[root@kafka-master kafka]# bin/kafka-console-consumer.sh --bootstrap-server master:9092 --topic topicname --from-beginning