[ https://issues.apache.org/jira/browse/KAFKA-15676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chris Egerton reassigned KAFKA-15676: ------------------------------------- Assignee: (was: Chris Egerton) > Scheduled rebalance delay for Connect is unnecessarily triggered when group > coordinator bounces > ----------------------------------------------------------------------------------------------- > > Key: KAFKA-15676 > URL: https://issues.apache.org/jira/browse/KAFKA-15676 > Project: Kafka > Issue Type: Bug > Components: KafkaConnect > Reporter: Chris Egerton > Priority: Major > > When a Connect worker loses contact with the group coordinator, it > voluntarily gives up (i.e., stops) its assignment of connectors and tasks > (for more context, see KAFKA-9184). However, this change in state is not > relayed to the worker's instance of the [IncrementalCooperativeAssignor > class|https://github.com/apache/kafka/blob/d144b7ee387308a59e52cbdabc7b66dd3b2926cc/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java]. > If the group coordinator for a Connect cluster is unavailable for long > enough, all of the workers in the cluster will revoke their assigned > connectors and tasks and, upon rejoining the group, report that they have > been assigned no connectors and tasks. > If a worker's member ID is reset before rejoining the group (which can happen > if, for example, the [maximum poll > interval|https://kafka.apache.org/documentation.html#consumerconfigs_max.poll.interval.ms] > for the worker is exceeded), the leader of the cluster will not act as if > the worker had rejoined the group; instead, it will act as if the worker had > left the group and a new, unrelated worker had joined during the same > rebalance. This will cause the scheduled rebalance delay to be triggered, and > for the connectors and tasks previously-assigned to that worker to remain > unassigned until the delay expires. -- This message was sent by Atlassian Jira (v8.20.10#820010)