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 E9A35200B26 for ; Mon, 13 Jun 2016 00:01:22 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id E86D2160A2C; Sun, 12 Jun 2016 22:01:22 +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 3C129160A04 for ; Mon, 13 Jun 2016 00:01:22 +0200 (CEST) Received: (qmail 21927 invoked by uid 500); 12 Jun 2016 22:01:21 -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 21914 invoked by uid 99); 12 Jun 2016 22:01:21 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 12 Jun 2016 22:01:21 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id E97DA2C1F5C for ; Sun, 12 Jun 2016 22:01:20 +0000 (UTC) Date: Sun, 12 Jun 2016 22:01:20 +0000 (UTC) From: "Jason Gustafson (JIRA)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Sun, 12 Jun 2016 22:01:23 -0000 [ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326653#comment-15326653 ] Jason Gustafson commented on KAFKA-2857: ---------------------------------------- [~imandhan] The __consumer_offsets topic is a normal topic, so it can happen that all the partition leaders and replicas are down, in which case we'll return an error saying the group coordinator is not available. The cluster has to be pretty big to hit this, but it can happen. It seems like our choices are basically to either let the command retry on this error, or try to give the user a more helpful message. I'd probably favor the latter. Since the most likely scenario for this case is the one mentioned in the description (where the topic hasn't been created yet), I think it would make sense to mention it explicitly in the message and let the user retry. > ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created > ----------------------------------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-2857 > URL: https://issues.apache.org/jira/browse/KAFKA-2857 > Project: Kafka > Issue Type: Bug > Components: tools > Reporter: Ismael Juma > Assignee: Ishita Mandhan > Priority: Minor > > If we describe a non-existing group before the offset topic is created, like the following: > {code} > bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --new-consumer --describe --group gggg > {code} > We get the following error: > {code} > Error while executing consumer group command The group coordinator is not available. > org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException: The group coordinator is not available. > {code} > The exception is thrown in the `adminClient.describeConsumerGroup` call. We can't interpret this exception as meaning that the group doesn't exist because it could also be thrown f all replicas for a offset topic partition are down (as explained by Jun). > Jun also suggested that we should distinguish if a coordinator is not available from the case where a coordinator doesn't exist. -- This message was sent by Atlassian JIRA (v6.3.4#6332)