【发布时间】：2020-10-29 06:27:05
【问题描述】：
我有一个生产者，它以字典列表的形式发送消息。消费者阅读消息，但我无法获取在最后“n”分钟内到达的消息。任何帮助将不胜感激。
【问题讨论】：
-
您可能会在字典列表中添加一个发布时间。然后，当您消费者获取数据时，它可以获取直到发布的时间离现在太远
-
我必须使用每条消息的处理时间来做到这一点。
标签： python apache-kafka kafka-python