This is an automated email from the ASF dual-hosted git repository. lucasbru pushed a commit to branch 4.1 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 8c4224057d149973217dad6084e7948eadb7c3ae Author: Lucas Brutschy <[email protected]> AuthorDate: Wed Jun 18 09:14:37 2025 +0200 MINOR: Add entity types in streams group RPCs (#19979) 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 all topic names. Reviewers: Matthias J. Sax <[email protected]> --- .../resources/common/message/StreamsGroupDescribeResponse.json | 6 +++--- .../resources/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 5dff3d7bf44..520a1ec4aee 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 247c3a68f54..8b63e037fc0 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 e7f7c0b7681..efeaf452571 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 +}
