kafka 安装入门：

kafka入门：

一。安装JDK

二。安装zk

参见：

参考资料：

三。安装kafka:

启动：/usr/local/zookeeper-3.4.13/bin/zkServer.sh start

启动：bin/kafka-server-start.sh config/server.properties

3.1 解压

3.1 启动ZooKeeper：

3.2 停止kafka

bin/kafka-server-stop.sh config/server.properties

4.1 创建topic

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo

4.2 查询topic列表

bin/kafka-topics.sh --list --zookeeper localhost:2181

4.3 查看topic信息

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic demo

4.3 删除topic

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic demo

四。操作：

5.1 启动生产者

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic demo

5.2 启动消费者：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic demo --from-beginning

5.3 查看kafka生产最大位置偏移量 kafka 安装入门：

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic demo --time -1

参考资料：