We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7bc9703 commit ccfbe54Copy full SHA for ccfbe54
test/test_record_accumulator.py
@@ -17,7 +17,7 @@ def test_producer_batch_producer_id():
17
magic=2, compression_type=0, batch_size=100000)
18
batch = ProducerBatch(tp, records)
19
assert batch.producer_id == -1
20
- batch.records.set_producer_state(123, 456, 789)
+ batch.records.set_producer_state(123, 456, 789, False)
21
assert batch.producer_id == 123
22
records.close()
23
0 commit comments