kafka-examples
kafka-examples copied to clipboard
offsetsForTimes returns only 1 or 2 partitions offset positions not all
Hi omkreddy,
I tried to reset my offset position by offsetsForTimes method but its failed to return all partitions offset position. Though I verified all partitions are assigned before calling offsetsForTimes method, it returns only 1 or 2 partitions (randomly) offset position.
I posted a stack overflow question on this https://stackoverflow.com/questions/59200574/
Any help will be appreciated.