[
https://issues.apache.org/jira/browse/KAFKA-20627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-20627:
-----------------------------------
Description:
StreamsGroupTopologyDescriptionRequestTest.scala (with plugin configured),
StreamsGroupTopologyDescriptionNoPluginRequestTest.scala (UNSUPPORTED_VERSION
behavior). TopologyDescriptionPluginIntegrationTest.java (end-to-end: push →
describe → delete). IntegrationTestHarness, GroupCoordinatorBaseRequestTest.
Add InMemoryTopologyDescriptionPlugin to
EmbeddedKafkaCluster.addDefaultBrokerPropsIfAbsent via putIfAbsent. This
enables the plugin in all streams integration tests without any per-test
changes, ensuring existing tests exercise the topology description path and
catch regressions.
TopologyDescriptionPluginIntegrationTest — 4 tests covering the core push
lifecycle on a live cluster:
- topology description reaches the plugin after join
- two-member group deduplicates: only one push happens
- permanent plugin failure ratchets failedDescriptionTopologyEpoch and stops
re-solicitation
- explicit DeleteGroups triggers plugin.deleteTopology
TopologyDescriptionPluginExpirationIntegrationTest — 2 tests covering natural
group expiry:
- group with stored topology: cleanup cycle calls plugin.deleteTopology and
clears the stored epoch before the offset-expiration sweep tombstones it
- group whose topology push permanently failed (storedEpoch == -1): tombstone
fires directly without any deleteTopology call
was:
StreamsGroupTopologyDescriptionRequestTest.scala (with plugin configured),
StreamsGroupTopologyDescriptionNoPluginRequestTest.scala (UNSUPPORTED_VERSION
behavior). TopologyDescriptionPluginIntegrationTest.java (end-to-end: push →
describe → delete). IntegrationTestHarness, GroupCoordinatorBaseRequestTest.
Add InMemoryTopologyDescriptionPlugin to
EmbeddedKafkaCluster.addDefaultBrokerPropsIfAbsent via putIfAbsent. This
enables the plugin in all streams integration tests without any per-test
changes, ensuring existing tests exercise the topology description path and
catch regressions.
> Add broker integration tests for topology description plugin
> ------------------------------------------------------------
>
> Key: KAFKA-20627
> URL: https://issues.apache.org/jira/browse/KAFKA-20627
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Alieh Saeedi
> Assignee: Alieh Saeedi
> Priority: Major
> Fix For: 4.4.0
>
>
> StreamsGroupTopologyDescriptionRequestTest.scala (with plugin configured),
> StreamsGroupTopologyDescriptionNoPluginRequestTest.scala (UNSUPPORTED_VERSION
> behavior). TopologyDescriptionPluginIntegrationTest.java (end-to-end: push →
> describe → delete). IntegrationTestHarness, GroupCoordinatorBaseRequestTest.
>
> Add InMemoryTopologyDescriptionPlugin to
> EmbeddedKafkaCluster.addDefaultBrokerPropsIfAbsent via putIfAbsent. This
> enables the plugin in all streams integration tests without any per-test
> changes, ensuring existing tests exercise the topology description path and
> catch regressions.
>
> TopologyDescriptionPluginIntegrationTest — 4 tests covering the core push
> lifecycle on a live cluster:
> - topology description reaches the plugin after join
> - two-member group deduplicates: only one push happens
> - permanent plugin failure ratchets failedDescriptionTopologyEpoch and
> stops re-solicitation
> - explicit DeleteGroups triggers plugin.deleteTopology
> TopologyDescriptionPluginExpirationIntegrationTest — 2 tests covering
> natural group expiry:
> - group with stored topology: cleanup cycle calls plugin.deleteTopology and
> clears the stored epoch before the offset-expiration sweep tombstones it
> - group whose topology push permanently failed (storedEpoch == -1):
> tombstone fires directly without any deleteTopology call
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
