Kafka python AvroConsumer seek 方法

【问题标题】：Kafka python AvroConsumer seek methodKafka python AvroConsumer seek 方法
【发布时间】：2019-05-01 17:36:03
【问题描述】：

我在使用 python 从给定偏移量消费时遇到问题，在 Java 中我实现了一个 KafkaConsumer 并使用了

consumer.seek(new TopicPartition(topic, 0), 3)

从我在分区 0 中的第三个偏移量消耗。

但是在使用 Python 时，我使用的是 AvroConsumer，它有一个 seek 方法，但只将分区作为参数，而不是从其消费的偏移量。它似乎从主题开始就消耗了。 AvroConsumer 有没有办法从某个偏移量消费？谢谢

【问题讨论】：

【解决方案1】：

您似乎在创建主题分区时提供了偏移量作为参数。

我没有你的代码示例来对此进行建模，所以我就这样写。

confluent_kafka.TopicPartition(topic,
                               partition,
                               offset)

consumer.seek(tp)

这是基于该代码库中的集成测试。我已经突出显示了相关测试并在下面链接

Integration Test For Confluent Kafka Python

【讨论】：