pinot
pinot copied to clipboard
Fix the issue of `fetchStreamPartitionOffset` method in Kafka 2.0 implementation
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.