GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2538
KAFKA-2857: Retry querying the consumer group while initializing
This applies to new-consumer based groups and would avoid scenarios in
which user issues a `--describe` query while the group is initializing.
Example: The following could occur for a newly created group.
```
kafka@kafka:~/workspace/kafka$ bin/kafka-consumer-groups.sh
--bootstrap-server localhost:9092 --describe --group g
Note: This will only show information about consumers that use the Java
consumer API (non-ZooKeeper-based consumers).
Error: Executing consumer group command failed due to The group coordinator
is not available.
```
With this PR the group is queried repeatedly at specific intervals within a
preset (and configurable) timeout `group-init-timeout` to circumvent
unfortunate situations like above.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka KAFKA-2857
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2538.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 #2538
----
commit 1e801041793d47bff2f3a4414b4bb7c3dd27ad04
Author: Vahid Hashemian <vahidhashem...@us.ibm.com>
Date: 2017-02-09T20:48:10Z
KAFKA-2857: Retry querying the consumer group while the group initializes
This applies to new-consumer based groups and would avoid scenarios in
which user issues a `--describe` query while the group is stabilizing.
Example: The following could occur for a newly created group.
```
kafka@kafka:~/workspace/kafka$ bin/kafka-consumer-groups.sh
--bootstrap-server localhost:9092 --describe --group g
Note: This will only show information about consumers that use the Java
consumer API (non-ZooKeeper-based consumers).
Error: Executing consumer group command failed due to The group coordinator
is not available.
```
With this PR the group is queried repeatedly at specific intervals within a
preset (and configurable) timeout `group-init-timeout` to circumvent
unfortunate situations like above.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
