From b03f3e4e4d22791a4fb510190835fb4e0d6a4886 Mon Sep 17 00:00:00 2001 From: Lucas Brutschy Date: Tue, 17 Jun 2025 14:09:49 +0200 Subject: [PATCH] MINOR: Add entity types in streams group RPCs These can be used to implement transformations on top of the RPC definitions. Group IDs were already marked. This PR additionally adds the entityType for topic names. --- .../common/message/StreamsGroupDescribeResponse.json | 6 +++--- .../common/message/StreamsGroupHeartbeatRequest.json | 10 +++++----- .../common/message/StreamsGroupHeartbeatResponse.json | 4 ++-- 3 files changed, 10 insertions(+), 10 deletions(-) diff --git a/clients/src/main/resources/common/message/StreamsGroupDescribeResponse.json b/clients/src/main/resources/common/message/StreamsGroupDescribeResponse.json index 5dff3d7bf4449..520a1ec4aee49 100644 --- a/clients/src/main/resources/common/message/StreamsGroupDescribeResponse.json +++ b/clients/src/main/resources/common/message/StreamsGroupDescribeResponse.json @@ -57,9 +57,9 @@ "fields": [ { "name": "SubtopologyId", "type": "string", "versions": "0+", "about": "String to uniquely identify the subtopology." }, - { "name": "SourceTopics", "type": "[]string", "versions": "0+", + { "name": "SourceTopics", "type": "[]string", "versions": "0+", "entityType": "topicName", "about": "The topics the subtopology reads from." }, - { "name": "RepartitionSinkTopics", "type": "[]string", "versions": "0+", + { "name": "RepartitionSinkTopics", "type": "[]string", "versions": "0+", "entityType": "topicName", "about": "The repartition topics the subtopology writes to." }, { "name": "StateChangelogTopics", "type": "[]TopicInfo", "versions": "0+", "about": "The set of state changelog topics associated with this subtopology. Created automatically." }, @@ -154,7 +154,7 @@ "about": "value of the config" } ]}, { "name": "TopicInfo", "versions": "0+", "fields": [ - { "name": "Name", "type": "string", "versions": "0+", + { "name": "Name", "type": "string", "versions": "0+", "entityType": "topicName", "about": "The name of the topic." }, { "name": "Partitions", "type": "int32", "versions": "0+", "about": "The number of partitions in the topic. Can be 0 if no specific number of partitions is enforced. Always 0 for changelog topics." }, diff --git a/clients/src/main/resources/common/message/StreamsGroupHeartbeatRequest.json b/clients/src/main/resources/common/message/StreamsGroupHeartbeatRequest.json index 247c3a68f548f..8b63e037fc0a1 100644 --- a/clients/src/main/resources/common/message/StreamsGroupHeartbeatRequest.json +++ b/clients/src/main/resources/common/message/StreamsGroupHeartbeatRequest.json @@ -20,7 +20,7 @@ "name": "StreamsGroupHeartbeatRequest", "validVersions": "0", "flexibleVersions": "0+", - // The StreamsGroupDescribeRequest API is added as part of KIP-1071 and is still under + // The StreamsGroupHeartbeatRequest API is added as part of KIP-1071 and is still under // development. Hence, the API is not exposed by default by brokers unless // explicitly enabled. "latestVersionUnstable": true, @@ -50,13 +50,13 @@ "fields": [ { "name": "SubtopologyId", "type": "string", "versions": "0+", "about": "String to uniquely identify the subtopology. Deterministically generated from the topology" }, - { "name": "SourceTopics", "type": "[]string", "versions": "0+", + { "name": "SourceTopics", "type": "[]string", "versions": "0+", "entityType": "topicName", "about": "The topics the topology reads from." }, { "name": "SourceTopicRegex", "type": "[]string", "versions": "0+", "about": "The regular expressions identifying topics the subtopology reads from." }, { "name": "StateChangelogTopics", "type": "[]TopicInfo", "versions": "0+", "about": "The set of state changelog topics associated with this subtopology. Created automatically." }, - { "name": "RepartitionSinkTopics", "type": "[]string", "versions": "0+", + { "name": "RepartitionSinkTopics", "type": "[]string", "versions": "0+", "entityType": "topicName", "about": "The repartition topics the subtopology writes to." }, { "name": "RepartitionSourceTopics", "type": "[]TopicInfo", "versions": "0+", "about": "The set of source topics that are internally created repartition topics. Created automatically." }, @@ -104,7 +104,7 @@ "about": "value of the config" } ]}, { "name": "TopicInfo", "versions": "0+", "fields": [ - { "name": "Name", "type": "string", "versions": "0+", + { "name": "Name", "type": "string", "versions": "0+", "entityType": "topicName", "about": "The name of the topic." }, { "name": "Partitions", "type": "int32", "versions": "0+", "about": "The number of partitions in the topic. Can be 0 if no specific number of partitions is enforced. Always 0 for changelog topics." }, @@ -135,4 +135,4 @@ "about": "The partitions of the input topics processed by this member." } ]} ] -} \ No newline at end of file +} diff --git a/clients/src/main/resources/common/message/StreamsGroupHeartbeatResponse.json b/clients/src/main/resources/common/message/StreamsGroupHeartbeatResponse.json index e7f7c0b768150..efeaf4525716f 100644 --- a/clients/src/main/resources/common/message/StreamsGroupHeartbeatResponse.json +++ b/clients/src/main/resources/common/message/StreamsGroupHeartbeatResponse.json @@ -100,7 +100,7 @@ "about": "A string representation of the status." } ]}, { "name": "TopicPartition", "versions": "0+", "fields": [ - { "name": "Topic", "type": "string", "versions": "0+", + { "name": "Topic", "type": "string", "versions": "0+", "entityType": "topicName", "about": "topic name" }, { "name": "Partitions", "type": "[]int32", "versions": "0+", "about": "partitions" } @@ -118,4 +118,4 @@ "about": "port of the endpoint" } ]} ] -} \ No newline at end of file +}