Kafka python AvroConsumer seek方法

Question

我在使用 python 从给定偏移量消耗时遇到问题，在 Java 我已经实现了 KafkaConsumer 并使用了

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

从分区 0 中的第三个偏移量开始使用。

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

Answer 1

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

我没有你的代码示例来模拟这个，所以我就这样写。

confluent_kafka.TopicPartition(topic,
                               partition,
                               offset)

consumer.seek(tp)

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

Integration Test For Confluent Kafka Python

Kafka python AvroConsumer seek method