Skip to content

Commit c8945c0

Browse files
committed
Fix byte size estimation with kafka producer
1 parent fb279d7 commit c8945c0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/producer/kafka.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -554,7 +554,7 @@ def send(self, topic, value=None, key=None, partition=None, timestamp_ms=None):
554554
partition = self._partition(topic, partition, key, value,
555555
key_bytes, value_bytes)
556556

557-
message_size = self._estimate_size_in_bytes(key, value)
557+
message_size = self._estimate_size_in_bytes(key_bytes, value_bytes)
558558
self._ensure_valid_record_size(message_size)
559559

560560
tp = TopicPartition(topic, partition)

0 commit comments

Comments
 (0)