Skip to content

Commit a3995b3

Browse files
authored
Replace periods (java) with underscores (python)
1 parent 307f5c4 commit a3995b3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kafka/coordinator/consumer.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -574,12 +574,12 @@ def _handle_offset_commit_response(self, offsets, future, send_time, response):
574574
" already rebalanced and assigned the partitions to"
575575
" another member. This means that the time between"
576576
" subsequent calls to poll() was longer than the"
577-
" configured session.timeout.ms, which typically"
577+
" configured session_timeout_ms, which typically"
578578
" implies that the poll loop is spending too much time"
579579
" message processing. You can address this either by"
580580
" increasing the session timeout or by reducing the"
581581
" maximum size of batches returned in poll() with"
582-
" max.poll.records."))
582+
" max_poll_records."))
583583
return
584584
else:
585585
log.error("Group %s failed to commit partition %s at offset"

0 commit comments

Comments
 (0)