没有项目描述
kafka-transport的Python项目详细描述
安装
` $ pip install kafka-transport `
使用
包包含init,push,subscribe,fetch异步函数:
` async init(kafka_host) async push(topic, value, key) async subscribe(topic, callback) async fetch(to, _from, value) `
待办事项 请求者:开始,组id
没有项目描述
` $ pip install kafka-transport `
包包含init,push,subscribe,fetch异步函数:
` async init(kafka_host) async push(topic, value, key) async subscribe(topic, callback) async fetch(to, _from, value) `
待办事项 请求者:开始,组id