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.