Пытался использовать сливающиеся функции паузы и возобновления потребителя kafka, но не смог найти в Интернете никаких примеров, кроме основной ссылки.
https://docs.confluent.io/5.0.0/clients/confluent-kafka-python/index.html
Не удалось понять передаваемые ему параметры. Либо список патентов, либо названия тем, что ли?
Сделайте паузу и возобновите, возьмите список _1 _
class confluent_kafka.TopicPartition
TopicPartition- это общий тип для хранения одного раздела и различной информации о нем.Обычно он используется для предоставления списка тем или разделов для различных операций, таких как Consumer.assign ().
TopicPartition(topic[, partition][, offset])Создайте экземпляр объекта TopicPartition.
Параметры:
topic(строка) - Название темыpartition(int) - Идентификатор разделаoffset(int) - Начальное смещение раздела
