From 8c5e061ff4a520c5d9694bbfd6c5a47516de1c98 Mon Sep 17 00:00:00 2001 From: Yash Mayya Date: Mon, 5 Jun 2023 17:47:50 +0530 Subject: [PATCH] MINOR: Remove reference to 'offset backing store' from exception message in KafkaBasedLog --- .../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 0432daf486a99..046d84923aec3 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 void start() { 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.");