这是python的测试台适配器：它允许您通过python轻松地将python服务连接到apache kafka测试台。
python-test-bed-adapter的Python项目详细描述
python测试台适配器
这是python的测试台适配器：它允许您轻松地连接python 通过python向apache-kafka测试台提供服务。尽管它是特别的 创建用于连接我们的test-bed， 它也适用于任何ApacheKafka版本。
实现是一个包装Pykafka 和avro-python3 支持：
- AVRO模式和消息：键和值都应该有一个模式 如here所述。
- 卡夫卡的消费者和生产者的试验台主题
- 管理
- heartbeat（主题：连接状态heartbeat），以便您知道哪些客户端处于联机状态。 每次执行测试台适配器时，它都会启动一个heartbeat进程来通知 对其他客户的ITS活动。
- 配置（主题：连接状态配置），以便您可以看到 客户消费和生产的主题。
安装
你需要安装Python 3+。
要安装PYPI包，请运行
pip3 install python-test-bed-adapter
使用github repo
如果克隆github存储库，要运行示例，需要安装依赖项
在文件中指定
requirements.txt
为此，快跑
pip3 install -r requirements.txt
从项目文件夹
示例和用法
欢迎加入QQ群-->： 979659372
