Usando o kafka-python-1.0.2.

Se eu tenho um tópico com 10 partições, como faço para confirmar uma partição específica, enquanto percorre as várias partições e mensagens. Eu simplesmente não consigo encontrar um exemplo disso em qualquer lugar, nos documentos ou de outra forma

Dos documentos, eu quero usar:

consumer.commit(offset=offsets)

Especificamente, como eu crio a partição e o dicionário OffsetAndMetadata necessários para as compensações (dict, opcional) - {TopicPartition: OffsetAndMetadata}.

Eu esperava que a chamada de função fosse algo como:

consumer.commit(partition, offset)

mas isso não parece ser o caso.

Desde já, obrigado.