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

Я хотел бы получить смещение для темы kafka.
Я попробовал код, упомянутый здесь: 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))

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


apache-kafka kafka-python
person Amr Keleg    schedule 03.05.2018    source источник
comment
Вы намерены найти последнее смещение раздела?   -  person void    schedule 03.05.2018
comment
@void Да, я хочу найти последнее смещение.   -  person Amr Keleg    schedule 03.05.2018
comment
Возможный дубликат Как получить последнее смещение для раздела для темы кафки?   -  person void    schedule 03.05.2018
comment
stackoverflow.com/a/44685608/2408270 проверьте это, OP   -  person void    schedule 03.05.2018