kafak 命令使用

本篇文章主要内容:

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下消费的偏移量都可以查看到

其它命令  点击这里

上一篇:tableviewCell折叠状态3


下一篇:Oracle11g R2学习系列 之一安装篇