[
https://issues.apache.org/jira/browse/KAFKA-20623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-20623:
--------------------------------------
Assignee: TengYao Chi (was: Lucas Brutschy)
> Wire topology description plugin into GroupCoordinatorService
> -------------------------------------------------------------
>
> Key: KAFKA-20623
> URL: https://issues.apache.org/jira/browse/KAFKA-20623
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Alieh Saeedi
> Assignee: TengYao Chi
> Priority: Major
> Fix For: 4.4.0
>
>
> Write path, heartbeat gating, delete:
> GroupCoordinatorService: builder plumbing for plugin. Heartbeat
> post-processing: set TopologyDescriptionRequired=true when
> StoredTopologyEpoch != currentTopologyEpoch AND LastFailedTopologyEpoch !=
> currentTopologyEpoch AND backoff not active (skip STALE_TOPOLOGY members).
> In-memory per-group exponential backoff (30s → 1h).
> StreamsGroupTopologyDescriptionUpdate handler: validate MemberId against
> current group membership (→ UNKNOWN_MEMBER_ID), call plugin.setTopology, on
> success write StoredTopologyEpoch metadata record, on permanent failure write
> LastFailedTopologyEpoch, on transient failure arm backoff. POJO↔wire
> converters. deleteGroups integration: call plugin.deleteTopology before
> tombstoning, return DELETE_FAILED on plugin failure. GroupCoordinator
> interface update. GroupCoordinatorServiceTest.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
