[
https://issues.apache.org/jira/browse/KAFKA-20622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi updated KAFKA-20622:
---------------------------------
Description: Plugin SPI interface in group-coordinator-api:
StreamsGroupTopologyDescriptionPlugin with setTopology(groupId, topologyEpoch,
description), deleteTopology(groupId), getTopology(groupId, topologyEpoch).
StreamsGroupTopologyDescription POJO (subtopologies, global stores,
source/processor/sink nodes),
StreamsTopologyDescriptionPermanentFailureException,
StreamsTopologyDescriptionTransientFailureException, package-info.java.
InMemoryTopologyDescriptionPlugin in server module +
InMemoryTopologyDescriptionPluginTest. GroupCoordinatorConfig (new
group.streams.topology.description.plugin.class config). build.gradle
dependency, checkstyle/import-control.xml.
> Define StreamsGroupTopologyDescriptionPlugin SPI and
> InMemoryTopologyDescriptionPlugin
> --------------------------------------------------------------------------------------
>
> Key: KAFKA-20622
> URL: https://issues.apache.org/jira/browse/KAFKA-20622
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Alieh Saeedi
> Priority: Major
> Fix For: 4.4.0
>
>
> Plugin SPI interface in group-coordinator-api:
> StreamsGroupTopologyDescriptionPlugin with setTopology(groupId,
> topologyEpoch, description), deleteTopology(groupId), getTopology(groupId,
> topologyEpoch). StreamsGroupTopologyDescription POJO (subtopologies, global
> stores, source/processor/sink nodes),
> StreamsTopologyDescriptionPermanentFailureException,
> StreamsTopologyDescriptionTransientFailureException, package-info.java.
> InMemoryTopologyDescriptionPlugin in server module +
> InMemoryTopologyDescriptionPluginTest. GroupCoordinatorConfig (new
> group.streams.topology.description.plugin.class config). build.gradle
> dependency, checkstyle/import-control.xml.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
