From fca7ee7270af55bf5f70f6ff05983ee229843186 Mon Sep 17 00:00:00 2001 From: Yash Mayya Date: Mon, 5 Jun 2023 15:04:17 +0100 Subject: [PATCH] MINOR: Remove reference to 'offset backing store' from exception message in KafkaBasedLog (#13810) Reviewers: Chris Egerton --- .../main/java/org/apache/kafka/connect/util/KafkaBasedLog.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java b/connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java index 0432daf486a..046d84923ae 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java @@ -257,7 +257,7 @@ public class KafkaBasedLog { partitionInfos = consumer.partitionsFor(topic); } if (partitionInfos.isEmpty()) - throw new ConnectException("Could not look up partition metadata for offset backing store topic in" + + throw new ConnectException("Could not look up partition metadata for topic '" + topic + "' in the" + " allotted period. This could indicate a connectivity issue, unavailable topic partitions, or if" + " this is your first use of the topic it may have taken too long to create.");