本篇文章主要内容:
kafka常用命令总结
一.kafka常用命令总结:
1.创建topic
bin/kafka-topics.sh --create --zookeeper ip:port/chroot --replication-factor num --partitions num --topic topic-name
ip:port/chroot-> kafka的zookeeper地址 num -> 数量 topic-name -> topic的名称 注:向kafka发送数据之前不一定要事先创建topic,可以直接指定topic发送数据。
2.向kafka发送数据
bin/kafka-console-producer.sh --broker-list broker-ip:port --topic topic-name
broker-ip:port -> broker地址 注:执行完此命令,可以直接在终端输入数据,按回车键发送,ctrl-c退出。
3.从kafka读取数据
#首先是跟读模式 bin/kafka-console-consumer.sh --zookeeper ip:port/chroot --topic topic-name 可以读取到实时发送到kafka的数据,不能读取到历史数据。 #从开始偏移量(offset)读取数据 bin/kafka-console-consumer.sh --zookeeper ip:port/chroot --topic topic-name --from-beginning 从topic起始位置开始读取。
4.查看kafkaz中 topic的列表
bin/kafka-topics.sh --list --zookeeper ip:port/chroot
5.查看某一个topic的详细信息
bin/kafka-topics.sh --describe --zookeeper ip:port/chroot --topic topic-name
6. 查看topic的消费偏移量
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper ip:port/chroot --group group-name 注:实际log消息数量和group下消费的偏移量都可以查看到
其它命令 点击这里