We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2119d4e commit 02ad21cCopy full SHA for 02ad21c
lib/kafka/protocol/message.rb
@@ -111,7 +111,6 @@ def self.decode(decoder)
111
# All other cases, compressed inner messages should have relative offset, with below attributes:
112
# - The container message should have the 'real' offset
113
# - The container message's offset should be the 'real' offset of the last message in the compressed batch
114
- # - The first inner message should always have offset = 0
115
def correct_offsets(message_set)
116
max_relative_offset = message_set.messages.last.offset
117
0 commit comments