Kafka是一个高吞吐量的分布式发布订阅消息系统，它在实时计算系统中有着非常强大的功能。通常情况下，使用Kafka构建系统或应用程序之间的数据管道，用来转换或响应实时数据，使数据能够及时地进行业务计算，得出相应结果
基础环境为zookeeper环境，也就是上篇文章配置好的集群(●'◡'●)
下载kafka
Index of /dist/kafka (apache.org)http://archive.apache.org/dist/kafka/
tar xf kafka_2.11-1.1.1.tgz ## ------- 配置 ------- vim kafka_2.11-1.1.1/config/server.properties 找到 broker.id=0 和 zookpeer.connect=localhost:2181 并注释 在三个节点的kafka配置文件添加： broker.id=1 #（与本机zookeeper的ID一致，在第二个节点就改为2，以此类推） zookeeper.connect=192.168.100.10:2181,192.168.100.20:2181,192.168.100.30:2181 #(三台节点的IP:2181) listeners=PLAINTEXT://192.168.100.10:9092 #（当前节点的IP:9092） ## ------- 启动 ------- (三个节点都启动) cd /root/kafka_2.11-1.1.1/bin ./kafka-server-start.sh -daemon ../config/server.properties ## ------ 测试 ------- [root@zookeeper1 bin]# ./kafka-topics.sh --create --zookeeper 192.168.100.10:2181 --replication-factor 1 --partitions 1 --topic test Created topic "test". [root@zookeeper2 bin]# ./kafka-topics.sh --list --zookeeper 192.168.100.20:2181 test [root@zookeeper3 bin]# ./kafka-topics.sh --list --zookeeper 192.168.100.30:2181 test
