GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/440
Do not merge: Multi-consumer integration tests for consumer group subsribe
and timeouts and corresponding fixes
A subset of changes for CPKAFKA-81 for initial review.
-- Refactored multi-consumer integration group assignment validation tests
for round-robin assignment
-- Added multi-consumer integration tests for session timeout expiration
-- Fixes to issues found with session timeout expiration tests woth help
from Jason Gustafson.
1. shouldKeepMemberAlive(): when we are in the sync phase, we do want
to expire members if we don't get any response
2. Try to avoid SendFailedException exception by cancelling the
scheduled tasks and ensuring metadata update before sending group leave
requests.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apovzner/kafka cpkafka81_01
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/440.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 #440
----
commit e00a864543e97c12e1f40d1f2317525f6f38a1be
Author: Anna Povzner <a...@confluent.io>
Date: 2015-11-06T04:02:55Z
Multi-consumer integration tests for consumer group subsribe and timeouts
and consumer timeout fixes.
-- Refactored multi-consumer integration group assignment validation tests
for round-robin assignment
-- Added multi-consumer integration tests for session timeout expiration
-- Fixes to issues found with session timeout expiration tests woth help
from Jason Gustafson.
1. shouldKeepMemberAlive(): when we are in the sync phase, we do want
to expire members if we don't get any response
2. Try to avoid SendFailedException exception by cancelling the
scheduled tasks and ensuring metadata update before sending group leave
requests.
----
---
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.
---
