kafka-python不支持zookeeper，PyKafka只支持2.7以上版本python，而centos6.5生产环境默认是2.6.6 ​​​​ 1、Python 版本：kafka-python 支持 2.6，不支持 3.5， PyKafak 支持 ...

://stackoom.com/question/3y2xB/kafka-python引发UnrecognizedBr ...

最近需要做一个订阅kafka中的消息并存入Phoenix中的项目，首先使用了pykakfa模块，代码如下： 在windows中运行正常，但是放到ubuntu14.04下，出现错误： 在官网https://github.com/Parsely/pykafka查看介绍 ...

1、导入模块 from pykafka import KafkaClient,common 2、实例化 3、生产者demo 4、消费者demo ...

...

使用方式 生产消息 python testkafka.py p g k 消费消息 python testkafka.py c g k ...

kafka简介（摘自百度百科） 简介： kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。 这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决 ...

①进入到kafka文件夹中修改配置文件：vim config/server.properties ②启动zookeeper： bin/zookeeper-server-start.sh config/zookeeper.properties 端口2181 ...