You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Onur Karaman (JIRA)" <ji...@apache.org> on 2015/06/04 21:57:40 UTC
[jira] [Commented] (KAFKA-2245) Add tests for ConsumerCoordinator
[ https://issues.apache.org/jira/browse/KAFKA-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14573479#comment-14573479 ]
Onur Karaman commented on KAFKA-2245:
-------------------------------------
Created reviewboard https://reviews.apache.org/r/35086/diff/
against branch origin/trunk
> Add tests for ConsumerCoordinator
> ---------------------------------
>
> Key: KAFKA-2245
> URL: https://issues.apache.org/jira/browse/KAFKA-2245
> Project: Kafka
> Issue Type: Sub-task
> Components: consumer
> Reporter: Onur Karaman
> Assignee: Onur Karaman
> Attachments: KAFKA-2245.patch
>
>
> We can validate error codes from JoinGroupResponses and HeartbeatResponses. Currently this includes:
> - JoinGroupRequest to the wrong coordinator returns NOT_COORDINATOR_FOR_CONSUMER
> - JoinGroupRequest with an unknown partition assignment strategy returns UNKNOWN_PARTITION_ASSIGNMENT_STRATEGY
> - JoinGroupRequest with an out-of-range session timeout returns INVALID_SESSION_TIMEOUT
> - JoinGroupRequest on a brand new group with an unrecognized consumer id produces UNKNOWN_CONSUMER_ID
> - JoinGroupRequest with mismatched partition assignment strategy compared to the rest of the group returns INCONSISTENT_PARTITION_ASSIGNMENT_STRATEGY
> - JoinGroupRequest on an existing group with an unrecognized consumer id produces UNKNOWN_CONSUMER_ID
> - A correct JoinGroupRequest returns NONE
> - HeartbeatRequest to the wrong coordinator returns NOT_COORDINATOR_FOR_CONSUMER
> - HeartbeatRequest with an unknown group returns UNKNOWN_CONSUMER_ID
> - HeartbeatRequest with an unrecognized consumer id returns UNKNOWN_CONSUMER_ID
> - HeartbeatRequest with generation id mismatch returns ILLEGAL_GENERATION
> - A correct HeartbeatRequest returns NONE
> We can validate the generation id increments on rebalance based on the JoinGroupResponse.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)