kafka python avroconsumer seek方法

j2cgzkjk 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(401)

我在使用python消耗给定偏移量时遇到问题，在java中我实现了一个kafkaconsumer并使用了 consumer.seek(new TopicPartition(topic, 0), 3) 使用分区0中的第三个偏移量。
但在使用python时，我使用的是avroconsumer，它有一个seek方法，但只将分区作为参数，而不是要使用的偏移量。似乎从主题一开始就开始消耗。avroconsumer有没有办法从某个偏移量开始消费？谢谢

avro python apache-kafka kafka-consumer-api confluent-platform

来源：https://stackoverflow.com/questions/53542697/kafka-python-avroconsumer-seek-method

1条答案

按热度按时间

fv2wmkja1#

在创建主题分区时，似乎提供了偏移量作为参数。
我没有你的代码的一个例子来模拟这个，所以我就这样写。

confluent_kafka.TopicPartition(topic,
                               partition,
                               offset)

consumer.seek(tp)

这是基于此代码库中的集成测试。我已经强调了相关的测试，并链接到下面
融合kafka-python的集成测试

赞(0）回复(0）举报 2021-06-07

我来回答

kafka python avroconsumer seek方法

1条答案

相关问题

热门标签

最新问答