KAFKA-18619: New consumer topic metadata events should set requireMet…

…adata flag
apache · Jan 22, 2025 · 2446388 · 2446388
1 parent 341e535
commit 2446388
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...n/java/org/apache/kafka/clients/consumer/internals/events/AbstractTopicMetadataEvent.java b/...n/java/org/apache/kafka/clients/consumer/internals/events/AbstractTopicMetadataEvent.java
@@ -26,4 +26,9 @@ public abstract class AbstractTopicMetadataEvent extends CompletableApplicationE
     protected AbstractTopicMetadataEvent(final Type type, final long deadlineMs) {
         super(type, deadlineMs);
     }
+
+    @Override
+    public boolean requireSubscriptionMetadata() {
+        return true;
+    }
 }