diff options
| author | Blake Embrey <hello@blakeembrey.com> | 2018-02-24 08:14:09 -0800 |
|---|---|---|
| committer | Taras Voinarovskyi <voyn1991@gmail.com> | 2018-02-24 18:14:09 +0200 |
| commit | e66d8c42c9ebec612093b96950df81b7355e4aab (patch) | |
| tree | e5891eeaad2624c2dd7746626a2100f3fbd9f7ef | |
| parent | fb279d7b968578cc389a699b812795d29248754d (diff) | |
| download | kafka-python-e66d8c42c9ebec612093b96950df81b7355e4aab.tar.gz | |
Fix byte size estimation with kafka producer (#1393)
| -rw-r--r-- | kafka/producer/kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index ae28779..4a93de6 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -554,7 +554,7 @@ class KafkaProducer(object): partition = self._partition(topic, partition, key, value, key_bytes, value_bytes) - message_size = self._estimate_size_in_bytes(key, value) + message_size = self._estimate_size_in_bytes(key_bytes, value_bytes) self._ensure_valid_record_size(message_size) tp = TopicPartition(topic, partition) |