How to consume the consumed message from the kafka topic based on offset please provide example in confluent kafka python

Question

Suppose the consumer has consumed the messages and it is not committed yet and we have many such messages.

How to consume the consumed message from the kafka topic based on offset ? please provide example in confluent_kafka python.

Answer 1

Hi@Amit,

You can pass --offset keyword in your command. Here’s the command to read records from the second partition starting at offset 6.

$ kafka-console-consumer --topic example-topic --bootstrap-server broker:9092 \
 --property print.key=true \
 --property key.separator="-" \
 --partition 1 \
 --offset 6