correct logs information in KafkaPartitionDiscoverer

apache · Apr 14, 2020 · 485ac22 · 485ac22
1 parent d241773
commit 485ac22
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ava/org/apache/flink/streaming/connectors/kafka/internal/Kafka010PartitionDiscoverer.java b/...ava/org/apache/flink/streaming/connectors/kafka/internal/Kafka010PartitionDiscoverer.java
@@ -77,7 +77,7 @@ protected List<KafkaTopicPartition> getAllPartitionsForTopics(List<String> topic
 				final List<PartitionInfo> kafkaPartitions = kafkaConsumer.partitionsFor(topic);
 
 				if (kafkaPartitions == null) {
-					throw new RuntimeException("Could not fetch partitions for %s. Make sure that the topic exists.".format(topic));
+					throw new RuntimeException(String.format("Could not fetch partitions for %s. Make sure that the topic exists.", topic));
 				}
 
 				for (PartitionInfo partitionInfo : kafkaPartitions) {