apache-kafka - 无法从使用 aiosfstream（Salesforce 的 Python 库）订阅的频道批量接收消息

Question

我正在尝试订阅 salesforce 频道，我能够从该频道获取消息。但问题是我一个接一个地收到消息，预期的接收方式是批量消息发布到频道时。需要在订阅者中整体获取消息。

假设我发布了 500 条消息，我需要在订阅服务器上获取全部 500 条消息。但我收到一条又一条的消息。

我正在使用以下代码

async with  client:
    for topic in get_topics(system='salesforce'):
        await client.subscribe(topic)
    async for message in client:
        messages = message

上面的代码在异步函数内部调用

我不确定这是来自库的错误或我遵循的方法是错误的

请让我知道是什么问题。

标签： apache-kafkasalesforcepython-asynciopython-3.7salesforce-lightning

Answer 1

我能够弄清楚这个问题，

它与图书馆无关，它非常棒。我能够实时收到消息。

问题出在我目前拥有的架构上，这导致了延迟。

谢谢大家的帮助。

我认为以这种方式回答不太好，但回答它可能会让某人抬头。在寻找此类错误时。

他们可以轻松地开始调试架构而不是库。