0

我正在尝试阅读 Kafka 主题中的所有消息。我正在使用融合云服务，所以不要在我的本地主机中运行 Kafka。我将配置设置为：'enable.auto.commit': 'True','auto.offset.reset': 'earliest', 'default.topic.config': {'auto.offset.reset': 'smallest'}. 但是，它没有给我任何消息，或者如果我同时从生产者发送消息，它只给出该消息而不是所有偏移消息。

如何在 python 中读取所有偏移量消息？

4

1 回答 1

0

我没有使用confluent云服务，如果要消耗所有偏移量，有几点需要注意。

  1. 设置不消耗任何数据的新消费者 groupId
  2. 设置 'auto.offset.rese=earliest' 或 'auto.offset.reset=smallest' ，需要参考kafka版本
  3. 注意Topic的自动过期日期
于 2020-10-16T10:01:00.730 回答