[
https://issues.apache.org/jira/browse/KAFKA-20621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-20621:
------------------------------------
Component/s: streams
> Add StoredTopologyEpoch and LastFailedTopologyEpoch to StreamsGroup model and
> metadata record
> ---------------------------------------------------------------------------------------------
>
> Key: KAFKA-20621
> URL: https://issues.apache.org/jira/browse/KAFKA-20621
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Alieh Saeedi
> Assignee: Lucas Brutschy
> Priority: Major
> Fix For: 4.4.0
>
>
> StreamsGroup: new timeline fields storedTopologyEpoch and
> lastFailedTopologyEpoch (int32, default -1). StreamsGroupMetadataValue.json:
> 2 new tagged fields (tags 3 and 4). StreamsCoordinatorRecordHelpers: plumb
> new fields through metadata record creation. StreamsGroupHeartbeatResult:
> carry the current topology epoch to the service layer.
> StreamsGroupDescribeResult (new record): bundle described groups with
> per-group storedTopologyEpoch. GroupCoordinatorShard: add
> validateStreamsGroupMember (validates group exists + member is current).
> GroupMetadataManager: update replay, heartbeat, fence, describe paths to
> read/write the new fields. Unit tests for all of the above.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
