kafka初体验（转载+自己）

1 下载kafka,并解压

2
启动Zookeeper server+Kafka server(首先进入文件目录)：

2.1启动Zookeeper server

Shell代码


bin/zookeeper-server-start.sh config/zookeeper.properties &

2.2启动Kafka server:

Shell代码


bin/kafka-server-start.sh config/server.properties &

3
创建topic+查看

创建：bin/kafka-topics.sh
--create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

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

4 运行producer+consumer：
4.1运行producer

Shell代码


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

4.2运行consumer：

Shell代码


bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

4.3 测试producer+consumer

在producer端输入字符串并回车，查看consumer端是否显示。

5
停止Kafka server +Zookeeper server(注：停止producer 、consumer：Ctrl+C)

5.1停止Kafka
server

Shell代码


bin/kafka-server-stop.sh

5.2停止Zookeeper server:

Shell代码


bin/zookeeper-server-stop.sh