kafka 安装

• 安装前提，kafka安装运行最低支持jdk7；

• 目前，Kafka已经内置了zookeeper，不需要单独下载zookeeper

• 启动

1. 启动zookeeper bin\windows\zookeeper-server-start.bat config\zookeeper.properties
   • 会报一个奇葩的错误，命令行太长，直接将压缩包解压到根目录或者桌面进行操作
2. 启动kafka
   • 启动kafka服务端命令bin\windows\kafka-server-start.bat config\server.properties

使用

1. 创建Topic bin/windows/kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test --partitions 1 --replication-factor 1 上述命令创造了test主题

2. 查看Topic bin/windows/kafka-topics.bat --list --bootstrap-server localhost:9092

3. 发送消息 前面介绍Kafka专业术语中已经阐述，Kafka使用过程中首先需要消息生产者发送消息，那么消费者才可以读取到消息。

启动一个终端A，执行下面命令，

bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic testhello

当执行producer脚本后，会出现消息输入提示符，这是我们可以输入消息(数据)，然后它会发送到对应的服务器(Broker)。

4. 接收消息 现在管道中已经有了数据，接下来我就可以使用消费者去读取数据。

另外启动一个终端B，执行下面命令，

./bin/windows/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test hello world