From 33d3769052e47a5f73fa90204f4bbb7d5cce4d4d Mon Sep 17 00:00:00 2001
From: Niels Zeilemaker <nielszeilemaker@godatadriven.com>
Date: Wed, 23 Mar 2016 16:40:25 +0100
Subject: [PATCH] FLINK-3663: FlinkKafkaConsumerBase.logPartitionInfo fix

---
 .../streaming/connectors/kafka/FlinkKafkaConsumerBase.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java b/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
index 51067d6bda4c0..5f20f16881ea6 100644
--- a/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
+++ b/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
@@ -217,7 +217,7 @@ public static void logPartitionInfo(List<KafkaTopicPartition> partitionInfos) {
 		for (Map.Entry<String, Integer> e : countPerTopic.entrySet()) {
 			sb.append(e.getKey()).append(" (").append(e.getValue()).append("), ");
 		}
-		LOG.info("Consumer is going to read the following topics (with number of partitions): ", sb.toString());
+		LOG.info("Consumer is going to read the following topics (with number of partitions): {}", sb.toString());
 	}