diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2017-11-07 15:16:06 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-11-07 15:16:06 -0800 |
| commit | a3995b38210d3700855d5b438529a5387c095569 (patch) | |
| tree | 86cc54daa7b4429f4a2f3a3a031f058314f86709 | |
| parent | 307f5c4a90eea6714f10ba2de7f84e5e88ae9c2d (diff) | |
| download | kafka-python-a3995b38210d3700855d5b438529a5387c095569.tar.gz | |
Replace periods (java) with underscores (python)
| -rw-r--r-- | kafka/coordinator/consumer.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 0328837..dee70f0 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -574,12 +574,12 @@ class ConsumerCoordinator(BaseCoordinator): " already rebalanced and assigned the partitions to" " another member. This means that the time between" " subsequent calls to poll() was longer than the" - " configured session.timeout.ms, which typically" + " configured session_timeout_ms, which typically" " implies that the poll loop is spending too much time" " message processing. You can address this either by" " increasing the session timeout or by reducing the" " maximum size of batches returned in poll() with" - " max.poll.records.")) + " max_poll_records.")) return else: log.error("Group %s failed to commit partition %s at offset" |