kafka使用命令

[飞飞侠]

##kafka使用命令
bin/kafka-server-start.sh /opt/kafka_2.11-0.10.2.0/config/server.properties   >/dev/null 2>&1 &


##查看创建的Topic，执行如下命令：
bin/kafka-topics.sh --create --zookeeper 192.168.1.71:2181/kafka  --replication-factor 1 --partitions 1 --topic mykafka

##修改Topic partitions数量
bin/kafka-topics.sh --alter --zookeeper 192.168.1.71:2181/kafka  --partitions 6 --topic  mykafka

##列出所有主题
bin/kafka-topics.sh --list --zookeeper 192.168.1.71:2181/kafka
bin/kafka-topics.sh --describe --zookeeper 192.168.1.71:2181/kafka --topic mykafka

##在一个终端，启动Producer，执行如下命令：
bin/kafka-console-producer.sh --broker-list 192.168.1.71:9092  --topic mykafka

##在另一个终端，启动Consumer，执行如下命令：
bin/kafka-console-consumer.sh --zookeeper 192.168.1.71:2181/kafka --topic mykafka --from-beginning

[作者]

帖子