一 介绍

Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据，下载地址如下：https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.2.0/kafka_2.11-0.10.2.0.tgz

二 启动

#启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
#更改配置
vi config/server.properties
#编辑内容如下
delete.topic.enable=true
listeners=PLAINTEXT://192.168.43.27:9092
#保存退出
#启动kafka服务端
bin/kafka-server-start.sh config/server.properties

三 创建主题

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
# 列出主题列表
bin/kafka-topics.sh --list --zookeeper localhost:2181
# 删除主题
bin/kafka-topics.sh  --delete --zookeeper 192.168.43.27:2181  --topic road

四 创建消息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
#发送消息
This is a message

This is another message

五 接收消息

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

this is a message
this is a another message

六 遇到的问题

在生产消息时，发生如下问题：

WARN Error while fetching metadata with correlation id 1 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

查看日志如下：

Registered broker 0 at path /brokers/ids/0 with addresses: 
PLAINTEXT -> EndPoint(218.30.64.194,9092,PLAINTEXT) (kafka.utils.ZkUtils)  

ip是218.30.64.194不是localhost，没有绑定Kafka启动监听的host信息，只需更改配置文件绑定即可。

vi  config/server.properties
#修改配置如下：
#原配置：listeners=PLAINTEXT://:9092  
listeners=PLAINTEXT://localhost:9092  

重修启动zookeeper和kafka即可。