Skip to content

Commit f53966c

Browse files
committed
Fix producer tests max_usable_produce_magic
1 parent 8ae67a7 commit f53966c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: test/test_producer.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ def test_kafka_producer_proper_record_metadata(kafka_broker, compression):
100100
retries=5,
101101
max_block_ms=30000,
102102
compression_type=compression) as producer:
103-
magic = producer._max_usable_produce_magic()
103+
magic = producer.max_usable_produce_magic(producer.config['api_version'])
104104

105105
# record headers are supported in 0.11.0
106106
if env_kafka_version() < (0, 11, 0):

0 commit comments

Comments
 (0)