Kafka操作工具。
项目描述
使用手册
快速开始
1）生产者
import kafkaplus
producer = kafkaplus.getProducer("localhost:9092")
# 发送一条消息
producer.send("test_topic", "data-a")
# 同步发送一条消息
producer.sendSync("test_topic", "data-b")
# 批量发送消息
producer.sendBatch("test_topic", "data1", "data2", "data3")
2）消费者
import kafkaplus
# 接收消息的回调函数
def callback(data, **kwargs):
print(data)
print(kwargs)
consumer = kafkaplus.getConsumer("localhost:9092")
# 监听topic，使用回调函数处理消息
consumer.onListener("test_topic",group="G-test",callback=callback)
下载文件
下载适用于您平台的文件。如果您不确定要选择哪个，请了解有关安装包的更多信息。
源分布
kafkaplus-0.0.1.tar.gz
(5.1 kB
查看哈希)
内置发行版
kafkaplus-0.0.1-py3.9.egg
（6.4 kB
查看哈希）
kafkaplus-0.0.1-py2.py3-none-any.whl
（3.6 kB
查看哈希）