Как получить разделы для темы кафки с помощью кафки-питона? - PullRequest
Новая
       15

Как получить разделы для темы кафки с помощью кафки-питона?

0 голосов
/ 03 мая 2018

Я хотел бы получить смещение для темы кафки.
Я попробовал код, упомянутый здесь: https://stackoverflow.com/a/44685608/2762279, но он не работает.

Я обнаружил, что для получения смещений требуется параметр раздела end_offsets(partitions).
Итак, я использовал базовый код, чтобы найти разделы для темы, однако он возвращает None. 

from kafka import KafkaConsumer

topic = 'TOPIC'
consumer = KafkaConsumer(
    topic,
    bootstrap_servers=['IP:PORT'],
    client_id = 'CLI',
    group_id='GR',
    auto_offset_reset='earliest',
    consumer_timeout_ms=10000)

print(consumer.partitions_for_topic(topic))

Должен ли я вызывать метод (какой-то тип соединения) перед получением разделов?

...