搭建Kafaka环境

1. 下载Kafaka

https://kafka.apache.org/downloads

2. 解压后修改配置

zookeeper.properties

Windows下例子：

dataDir=d:/tool/kafka/zookeeper

这个地方就是设置一个有效的访问路径。

server.properties

Windows下的例子：

log.dirs=d:/tool/kafka/kafka-logs

这个地方也是设置一个有效的访问路径。

3. 启动Zookeeper, 启动Kafaka之前一定要先启动Zookeeper。

Windows下的启动命令示例为：

zookeeper-server-start.bat "..\..\config\zookeeper.properties"
启动成功会看到如下的输出：

4. 启动Kafka

Windows下的启动命令示例为：

kafka-server-start.bat "..\..\config\server.properties"

5. Create a topic.

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic TestTopic

6. List Topic

kafka-topics.bat --list --zookeeper localhost:2181 

7. Producer produces messages:

kafka-console-producer.bat --broker-list localhost:9092 --topic TestTopic

8. Consumer consumes messages:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic TestTopic --from-beginning