Skip to content

Commit 56a0476

Browse files
committed
Updated to ignore all control batches
Control batches can show up even outside of transactions. This change drops the requirement that you must be in a transaction for a record to be labled a control batch.
1 parent a56d16b commit 56a0476

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)