Кафка питон AvroConsumer искать метод

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)

Это основано на интеграционном тесте в библиотеке для этого кода.Я выделил соответствующий тест и дал ссылку ниже

Интеграционный тест для Confluent Kafka Python