Пример функциональной возможности паузы-возобновления слияния kafka python

Question

Пытался использовать функцию паузы и возобновления потребителя конфлюентной кафки, но не мог найти никаких примеров через Интернет, кроме главной ссылки.

https://docs.confluent.io/5.0.0/clients/confluent-kafka-python/index.html

Не удалось понять параметры длябыть переданным к нему.Или его список патентов или названий тем или что?

Answer 1

Требуется список TopicPartition

class confluent_kafka.TopicPartition

TopicPartition - универсальный тип для хранения одного раздела и различной информацииоб этом.

Обычно используется для предоставления списка тем или разделов для различных операций, таких как Consumer.assign ().

TopicPartition(topic[, partition][, offset])

Создание экземпляра aОбъект TopicPartition.
Параметры:

• topic (строка) - Имя темы
• partition (int) - Идентификатор раздела
• offset(int) - Начальное смещение раздела