MINOR: Fix SubscriptionInfoData name in exception message (apache#12076)

Reviewers: Andrew Choi <[email protected]>, Luke Chen <[email protected]>
EricMinick · Oct 31, 2022 · 56d588d · 56d588d
1 parent f7304db
commit 56d588d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...c/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java b/...c/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 + "].");
         }