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