KAFKA-20629: Add ducktape system tests for topology description plugin[1/2]#22724
Open
lucliu1108 wants to merge 5 commits into
Open
KAFKA-20629: Add ducktape system tests for topology description plugin[1/2]#22724lucliu1108 wants to merge 5 commits into
lucliu1108 wants to merge 5 commits into
Conversation
…n (1/2)
Introduces the system-test infrastructure for KIP-1331 (Streams Group
Topology Description Plugin):
- New Java driver TopologyDescriptionPluginSystemTest that starts a
small streams app and exits on signal.
- New ducktape suite streams_topology_description_plugin_test with
three scenarios:
* push round-trip succeeds when the plugin is configured and the
client default push is on;
* client opt-out via topology.description.push.enabled=false
prevents the client from ever sending a description;
* no plugin on the broker means no solicitation is issued.
- KafkaService constructor parameter
streams_group_topology_description_plugin_class and matching
config_property constant to propagate
group.streams.topology.description.plugin.class to brokers.
- StreamsTopologyDescriptionPluginService and the supporting
TOPOLOGY_DESCRIPTION_PUSH_ENABLED property constant for the new
driver.
Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
lucliu1108
changed the title
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Introduces the system-test infrastructure for KIP-1331 (Streams Group Topology Description Plugin):
TopologyDescriptionPluginSystemTestthat starts a small streams app and exits on signal.streams_topology_description_plugin_testwith 3 scenarios: