diff options
| author | Taras <voyn1991@gmail.com> | 2017-10-12 11:07:14 +0300 |
|---|---|---|
| committer | Taras <voyn1991@gmail.com> | 2017-10-12 11:10:44 +0300 |
| commit | d10051bb09942bfd48c6f262a8cdbf5651963c2e (patch) | |
| tree | 1f6a262324e3ced9c8655d71fbed5e9ed8a0234d /kafka/producer/kafka.py | |
| parent | e992fbfad926486766ff7b63a499f9cf29984fec (diff) | |
| download | kafka-python-d10051bb09942bfd48c6f262a8cdbf5651963c2e.tar.gz | |
Added minor fixes for PR review
Diffstat (limited to 'kafka/producer/kafka.py')
| -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 a53ac49..5638b61 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -370,7 +370,7 @@ class KafkaProducer(object): else: checker, compression_attrs = self._COMPRESSORS[ct] assert checker(), "Libraries for {} compression codec not found".format(ct) - self.config['compression_type'] = compression_attrs + self.config['compression_attrs'] = compression_attrs message_version = self._max_usable_produce_magic() self._accumulator = RecordAccumulator(message_version=message_version, metrics=self._metrics, **self.config) |