Skip to content

Commit 733a47d

Browse files
authored
Merge pull request #893 from rkruze/record_batch
Updated to ignore all control batches
2 parents 1e28e9b + 56a0476 commit 733a47d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/kafka/protocol/record_batch.rb

+1-1
Original file line numberDiff line numberDiff line change
@@ -213,7 +213,7 @@ def self.decode(decoder)
213213
end
214214

215215
def mark_control_record
216-
if in_transaction && is_control_batch
216+
if is_control_batch
217217
record = @records.first
218218
record.is_control_record = true unless record.nil?
219219
end

0 commit comments

Comments
 (0)