from confluent_kafka import Consumer, KafkaError, TopicPartition c = Consumer({ 'bootstrap.servers': 'localhost', 'group.id': 'bob-group', 'default.topic.config': { 'auto.offset.reset': 'smallest', } }) c.subscribe(['topic-test']) tp = TopicPartition('topic-test', 0, 10) #msg = c.poll() #shouldn't be necessary think fault in client c.seek(tp) 

Traceback (most recent call last): File "kafka.confluent.consumer.py", line 29, in <module> c.seek(tp) cimpl.KafkaException: KafkaError{code=_UNKNOWN_PARTITION,val=-190,str="Failed to seek to offset 10: Local: Unknown partition"}