diff options
| author | flaneur <me.ssword@gmail.com> | 2018-11-11 04:45:51 +0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-11-10 12:45:51 -0800 |
| commit | 1c0e8942dc75837a2e43b93e0ed6700fb7752a03 (patch) | |
| tree | c526bfc738c0cd93709fb849a8d2346888bbe0e5 /kafka/producer/kafka.py | |
| parent | 0a2ccba3cb1b8636f615a30821123720773a8dfa (diff) | |
| download | kafka-python-1c0e8942dc75837a2e43b93e0ed6700fb7752a03.tar.gz | |
set socket timeout for the wake_w (#1577)
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 |