You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Chris Egerton (Jira)" <ji...@apache.org> on 2021/02/01 13:53:00 UTC
[jira] [Created] (KAFKA-12262) New session keys are never
distributed when follower with key becomes leader
Chris Egerton created KAFKA-12262:
-------------------------------------
Summary: New session keys are never distributed when follower with key becomes leader
Key: KAFKA-12262
URL: https://issues.apache.org/jira/browse/KAFKA-12262
Project: Kafka
Issue Type: Bug
Reporter: Chris Egerton
Assignee: Chris Egerton
The expiration time for session keys [starts at {{Long.MAX_VALUE}}|https://github.com/apache/kafka/blob/1c00d9dfa50570b4554a123bfe91ccc5e9ad1ca9/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java#L258] and [is updated when a new session key is read if and only if the worker is the leader|https://github.com/apache/kafka/blob/1c00d9dfa50570b4554a123bfe91ccc5e9ad1ca9/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java#L1579-L1581]. If a follower reads a session key from the config topic, the expiration time will remain {{Long.MAX_VALUE}} and, even if the worker becomes the leader, will not be updated.
Once this happens, all key rotation will cease until and unless the former leader of the cluster becomes the leader again without being restarted in the meantime.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)