From 56d588d55ac313c0efca586a3bcd984c99a89018 Mon Sep 17 00:00:00 2001 From: dengziming Date: Mon, 31 Oct 2022 10:48:16 +0800 Subject: [PATCH] MINOR: Fix SubscriptionInfoData name in exception message (#12076) Reviewers: Andrew Choi , Luke Chen --- .../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 71168c7d087d9..268192c5cfc8b 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 + "]."); }