diff options
Diffstat (limited to 'kafka/producer/kafka.py')
| -rw-r--r-- | kafka/producer/kafka.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index 7878c0a..45bb058 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -368,6 +368,7 @@ class KafkaProducer(object): self._metrics = Metrics(metric_config, reporters) client = KafkaClient(metrics=self._metrics, metric_group_prefix='producer', + wakeup_timeout_ms=self.config['max_block_ms'], **self.config) # Get auto-discovered version from client if necessary |