(kafka) branch trunk updated: MINOR: fix typo

[mj...@apache.org]

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

mjsax 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 1a2f74be67c MINOR: fix typo
1a2f74be67c is described below

commit 1a2f74be67cae1f8a337dfe5d7052c1cab8aac09
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Fri Dec 1 15:39:05 2023 -0800

    MINOR: fix typo
---
 .../org/apache/kafka/streams/processor/internals/RepartitionTopics.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java
index b8698bc6e56..39e429aab94 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java
@@ -156,7 +156,7 @@ public class RepartitionTopics {
                 if (!missingSourceTopicsForSubtopology.isEmpty()) {
                     final Subtopology subtopology = subtopologyEntry.getKey();
                     missingInputTopicsBySubtopology.put(subtopology, missingSourceTopicsForSubtopology);
-                    log.error("Subtopology {} was missing source topics {} and will be excluded from the current assignment, "
+                    log.error("Subtopology {} has missing source topics {} and will be excluded from the current assignment, "
                         + "this can be due to the consumer client's metadata being stale or because they have "
                         + "not been created yet. Please verify that you have created all input topics; if they "
                         + "do exist, you just need to wait for the metadata to be updated, at which time a new "