[
https://issues.apache.org/jira/browse/KAFKA-20621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi updated KAFKA-20621:
---------------------------------
Description: 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.
> 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
> 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)
