This interface: consumer->start(topic, kpartition, startoffset);
I want to start from a specific offset. if this offset is lower than the smallest offset currently in Kafka, then this interface will read from the end.
Exp, if current data on kafka is of offset from 1000-2000. If I want to start read from 900, then this interface will start read from 2000, since 900 is not on Kakfa. I think the reasonable result should be start from 1000(the smallest offset greater than 900).
how to solve this?
How to reproduce
Checklist
Please provide the following information:
[ ] librdkafka version (release number or git tag):
[ ] Apache Kafka version:
[ ] librdkafka client configuration:
[ ] Operating system:
[ ] Using the legacy Consumer
[ ] Using the high-level KafkaConsumer
[ ] Provide logs (with debug=.. as necessary) from librdkafka
Description
This interface: consumer->start(topic, kpartition, startoffset); I want to start from a specific offset. if this offset is lower than the smallest offset currently in Kafka, then this interface will read from the end. Exp, if current data on kafka is of offset from 1000-2000. If I want to start read from 900, then this interface will start read from 2000, since 900 is not on Kakfa. I think the reasonable result should be start from 1000(the smallest offset greater than 900).
how to solve this?
How to reproduce
Checklist
Please provide the following information:
debug=..
as necessary) from librdkafka