Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 9A705200D50 for ; Mon, 4 Dec 2017 10:01:13 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 98E59160C05; Mon, 4 Dec 2017 09:01:13 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 134BC160BF9 for ; Mon, 4 Dec 2017 10:01:12 +0100 (CET) Received: (qmail 69707 invoked by uid 500); 4 Dec 2017 09:01:11 -0000 Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list dev@kafka.apache.org Received: (qmail 69684 invoked by uid 99); 4 Dec 2017 09:01:11 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 04 Dec 2017 09:01:11 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 6ED24E0219; Mon, 4 Dec 2017 09:01:11 +0000 (UTC) From: leonhong To: dev@kafka.apache.org Reply-To: dev@kafka.apache.org Message-ID: Subject: [GitHub] kafka pull request #4290: Auto-commit of offsets fail, and not recover forev... Content-Type: text/plain Date: Mon, 4 Dec 2017 09:01:11 +0000 (UTC) archived-at: Mon, 04 Dec 2017 09:01:13 -0000 GitHub user leonhong opened a pull request: https://github.com/apache/kafka/pull/4290 Auto-commit of offsets fail, and not recover forever... * Auto-commit of offsets fail, and not recover **forever**. at sendOffsetCommitRequest, while "generation equal NULL", ConsumerCoordinator request will fail always. it maybe a bug. error log below: has more and more warn log .... "2017-12-01 22:08:39.112 WARN pool-390-thread-1#1 (ConsumerCoordinator.java:626) - Auto-commit of offsets {drawing_gift_sent-1=OffsetAndMetadata{offset=32150359, metadata=''}} failed for group gift_rich_audience_write: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.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." You can merge this pull request into a Git repository by running: $ git pull https://github.com/leonhong/kafka Auto-commit-fail-bugs Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4290.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4290 ---- commit bd27b5ba84433a29d6e28e0eeb7489378c0643b9 Author: hongliang Date: 2017-12-04T08:50:31Z Auto-commit of offsets fail, and not recover forever... ---- ---