文件名称:kafka-demo:适用于Apache Kafka的简单演示Python客户端脚本
文件大小:5KB
文件格式:ZIP
更新时间:2024-05-23 19:26:53
Python
Kafka演示脚本 这是我在PyConZA 2015上有关Apache Kafka的演讲中附带的演示工具包。 它包含用于演示生产者和平衡消费者的脚本。 您可以在此处观看演讲: 依存关系 该演示需要Kafka 0.8.2。 如果您无权访问Kafka群集,则可以通过在以下位置下载来以独立模式进行设置: 并按照此处的说明进行安装: 您还将需要pykafka客户端库。 我使用的版本是2.0.0,这是撰写本文时的最新版本。 使用它 pip install pykafka 或从此处的源仓库中获取: 配置 在此存储库中编辑settings.conf以连接到您的Kafka和Zookeeper主机。 默认情况下,它是为在localhost上进行独立的Kafka安装而设置的。 为了使以下测试正常运行,请通过执行以下操作创建一个名为“ test”的主题 cd /opt/kafka # This is
【文件预览】:
kafka-demo-master
----LICENCE.txt(1KB)
----demo-consumer.py(1KB)
----settings.conf(294B)
----README.md(4KB)
----demo-producer.py(1KB)
----.gitignore(9B)