Skip to content

Commit 92b4b6b

Browse files
committed
Build fixes
1 parent ee61203 commit 92b4b6b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

tests/integration/serialization/test_serializers.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -122,12 +122,12 @@ def test_mixed_serialization(kafka_single_broker_cluster, key_serializer, value_
122122
topic = kafka_single_broker_cluster.create_topic("serialization-numeric")
123123

124124
producer = kafka_single_broker_cluster.producer(key_serializer=key_serializer,
125-
value_serializer=value_serializer)
125+
value_serializer=value_serializer)
126126
producer.produce(topic, key=key, value=value)
127127
producer.flush()
128128

129129
consumer = kafka_single_broker_cluster.consumer(key_deserializer=key_deserializer,
130-
value_deserializer=value_deserializer)
130+
value_deserializer=value_deserializer)
131131
consumer.subscribe([topic])
132132

133133
msg = consumer.poll()

0 commit comments

Comments
 (0)