summaryrefslogtreecommitdiff
path: root/test/test_producer.py
diff options
context:
space:
mode:
Diffstat (limited to 'test/test_producer.py')
-rw-r--r--test/test_producer.py10
1 files changed, 9 insertions, 1 deletions
diff --git a/test/test_producer.py b/test/test_producer.py
index 09d184f..176b239 100644
--- a/test/test_producer.py
+++ b/test/test_producer.py
@@ -91,10 +91,16 @@ def test_kafka_producer_proper_record_metadata(kafka_broker, compression):
compression_type=compression)
magic = producer._max_usable_produce_magic()
+ # record headers are supported in 0.11.0
+ if version() < (0, 11, 0):
+ headers = None
+ else:
+ headers = [("Header Key", b"Header Value")]
+
topic = random_string(5)
future = producer.send(
topic,
- value=b"Simple value", key=b"Simple key", timestamp_ms=9999999,
+ value=b"Simple value", key=b"Simple key", headers=headers, timestamp_ms=9999999,
partition=0)
record = future.get(timeout=5)
assert record is not None
@@ -116,6 +122,8 @@ def test_kafka_producer_proper_record_metadata(kafka_broker, compression):
assert record.serialized_key_size == 10
assert record.serialized_value_size == 12
+ if headers:
+ assert record.serialized_header_size == 22
# generated timestamp case is skipped for broker 0.9 and below
if magic == 0: