diff options
| -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" |