pymapr-kafkarest

介绍

该项目的目的是为 MAPR Kafka REST 代理创建一个超级简单的包装器。我们试图让用户以基本的方式与 MAPR Kafka 进行交互，并尽可能减少编写代码。

可以在此处找到 REST 调用的原始文档。

安装

很快可以通过 pip 获得：

pip install pymapr-kafkarest

运行时配置

• KAFKAREST_LOG_LEVEL：允许设置日志级别...默认为DEBUG

待定

用法

导入库

from pymapr_kafkarest import MaprKlient

定义基本属性

base_url = 'http://my-endopoint:8082'
user_group = 'foo'
topics = ['/streams/foo:bar']

并实例化客户端

mk = MaprKlient(base_url, user_group, topics=topics)

连接、订阅和消费消息如下：

base_url = 'http://my-endopoint:8082'

if __name__ == '__main__':
    mk = MaprKlient(base_url, user_group, headers=headers, topics=topics)
    mk.connect(clear=True)
    mk.subscribe()
    
    messages = mk.consume()
    
    print(messages)

连接并产生消息：

from pymapr_kafkarest import MaprKlient
从 pymapr_kafkarest.kafkarest 导入 MaprKProducer

base_url  =  'https://localhost:8082'
标头 =  {} 
user_group  =  '我'

如果 __name__  ==  '__main__' ：

    # 生产
    mp  =  MaprKProducer ( base_url ,  user_group ,  headers = headers )

    msgs  =  [ dict ( key = '0099' ,  value = dict ( color = 'red' ,  shape = 'square' ))]

    议员。产生（消息= msgs ， 主题= '/streams/foo' ）

去做

• 很多方法还没有实现
• 完整阅读文档
• 链connect，subscribe并consume在一个名为的新方法中stream