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 e4348ff commit a23195cCopy full SHA for a23195c
lib/kafka/offset_manager.rb
@@ -58,7 +58,7 @@ def mark_as_processed(topic, partition, offset)
58
59
last_processed_offset = @processed_offsets[topic][partition] || -1
60
if last_processed_offset > offset + 1
61
- @logger.debug "Not overwriting newer offset #{topic}/#{partition}:#{last_processed_offset-1} with older #{offset}"
+ @logger.debug "Not overwriting newer offset #{topic}/#{partition}:#{last_processed_offset - 1} with older #{offset}"
62
return
63
end
64
0 commit comments