Update files

bakdata · Feb 16, 2024 · 5e7a964 · 5e7a964
1 parent 590aec3
commit 5e7a964
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/bakdata/kafka/KafkaConnectorSourceResetter.java b/src/main/java/com/bakdata/kafka/KafkaConnectorSourceResetter.java
@@ -192,7 +192,7 @@ private Consumer<byte[], byte[]> createConsumer(final Map<String, Object> kafkaC
     private <K, V> List<PartitionInfo> partitionsForOffsetTopic(final Consumer<K, V> consumer) {
         final Map<String, List<PartitionInfo>> topicsWithPartition = consumer.listTopics();
         if (!topicsWithPartition.containsKey(this.offsetTopic)) {
-            final String message = String.format("Topic %s does not exist.", this.offsetTopic);
+            final String message = String.format("Topic '%s' does not exist.", this.offsetTopic);
             throw new IllegalArgumentException(message);
         }
         return topicsWithPartition.get(this.offsetTopic);