Использование kafka-python-1.0.2.

Если у меня есть тема с 10 разделами, как мне выполнить фиксацию определенного раздела, одновременно просматривая различные разделы и сообщения. Я просто не могу найти пример этого где-нибудь, в документах или иным образом

Из документов я хочу использовать:

consumer.commit(offset=offsets)

В частности, как создать раздел и словарь OffsetAndMetadata, необходимые для смещений (dict, необязательный) - {TopicPartition: OffsetAndMetadata}.

Я надеялся, что вызов функции будет выглядеть примерно так:

consumer.commit(partition, offset)

но, похоже, это не так.

Заранее спасибо.