kafka-go icon indicating copy to clipboard operation
kafka-go copied to clipboard

Published 20 hours ago • verified publisher icon segmentio

conn.ReadOffsets and related functions should honor isolation level

Open stevevls opened this issue 5 years ago • 1 comments

Describe the solution you'd like Seeking to the end of a partition is probably broken for users that write messages with transactional producers. Because we're not setting the isolation level when we find the last offset, we may seek beyond the last stable offset.

Supporting documentation As part of KIP-98, a field for isolation_level was added to the v2 of ListOffsetsRequest. See also: https://kafka.apache.org/protocol#The_Messages_ListOffsets.

stevevls avatar Feb 26 '20 19:02 stevevls

Related work:

  • https://github.com/segmentio/kafka-go/pull/755

achille-roussel avatar Oct 29 '21 16:10 achille-roussel