[kafka] branch trunk updated: MINOR: Fix SubscriptionInfoData name in exception message (#12076)

[de...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dengziming pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 56d588d55ac MINOR: Fix SubscriptionInfoData name in exception message (#12076)
56d588d55ac is described below

commit 56d588d55ac313c0efca586a3bcd984c99a89018
Author: dengziming <de...@gmail.com>
AuthorDate: Mon Oct 31 10:48:16 2022 +0800

    MINOR: Fix SubscriptionInfoData name in exception message (#12076)
    
    Reviewers: Andrew Choi <an...@users.noreply.github.com>, Luke Chen <sh...@gmail.com>
---
 .../streams/processor/internals/assignment/SubscriptionInfo.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java
index 71168c7d087..268192c5cfc 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java
@@ -60,10 +60,10 @@ public class SubscriptionInfo {
 
     static {
         // Just statically check to make sure that the generated code always stays in sync with the overall protocol
-        final int subscriptionInfoLatestVersion = SubscriptionInfoData.SCHEMAS.length - 1;
+        final int subscriptionInfoLatestVersion = SubscriptionInfoData.HIGHEST_SUPPORTED_VERSION;
         if (subscriptionInfoLatestVersion != LATEST_SUPPORTED_VERSION) {
             throw new IllegalArgumentException(
-                "streams/src/main/resources/common/message/SubscriptionInfo.json needs to be updated to match the " +
+                "streams/src/main/resources/common/message/SubscriptionInfoData.json needs to be updated to match the " +
                     "latest assignment protocol version. SubscriptionInfo only supports up to  ["
                     + subscriptionInfoLatestVersion + "] but needs to support up to [" + LATEST_SUPPORTED_VERSION + "].");
         }