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 ...