DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
Node grouping. A nodeGroup field on TopologyNode for UI grouping, requiring an extension to the public TopologyDescription.Node interface in Kafka Streams — best addressed in a follow-up KIP.
Test Plan
Integration Tests
Broker:
UpdateStreamsGroupTopologyDescriptionRequestTest(new) — push happy path; permanent and transient plugin failures; heartbeat-flag gating; member/group/MemberIdfencing; explicitDeleteGroupsordering.UpdateStreamsGroupTopologyDescriptionNoPluginRequestTest(new) — broker without plugin: pushes rejected, flag never set, describe returnsNOT_STORED.AuthorizerIntegrationTest—READACL on the GROUP resource for the new RPC.
...
TopologyDescriptionFormatterTest(new) — eachTopologyDescriptionStatus, the pretty-print format, and the exit-code mapping.StreamsGroupCommandTest— the--topologysub-action against a populated group.
System Tests
New ducktape suite streams_topology_description_plugin_test.py driving the Java harness TopologyDescriptionPluginSystemTest:
...