pinot icon indicating copy to clipboard operation
pinot copied to clipboard

Fix the issue of `fetchStreamPartitionOffset` method in Kafka 2.0 implementation

Open sajjad-moradi opened this issue 2 years ago • 0 comments

Kafka 2.0 implementation of StreamMetadataProvider.fetchStreamPartitionOffset() returns the next offset after the last available offset while all other implementations correctly return the last available offset. This needs to be fixed. This causes issues on startup when offset based consumption status checker is used.

sajjad-moradi avatar Aug 29 '22 02:08 sajjad-moradi