文件配置

server.properties
broker.id=0 不同的server.properties里id需设置不用供识别
delete.topic.enable=true 因topic为自定义创建所以打开
log.dirs=/home/……  kafka存储数据的目录（不仅指日志）   log.rentention.hours、log.segemet.bytes
zookeeeper.connect=IP:2181,……

python安装

git clone https://github.com/mumrah/kafka-python
cd kafka-python
python setup.py install