Fix typo in warning log.

spring-attic · Apr 26, 2018 · 77b8083 · 77b8083
1 parent 777d0cd
commit 77b8083
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java b/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java
@@ -229,8 +229,8 @@ private ConsumerFactory<K, V> fixOrRejectConsumerFactory(ConsumerFactory<K, V> s
 			}
 			if (this.logger.isWarnEnabled()) {
 				this.logger.warn("'" + ConsumerConfig.MAX_POLL_RECORDS_CONFIG
-					+ "' has been forced to from " + (maxPoll == null ? "unspecified" : maxPoll)
-					+ "to 1, to avoid having to seek after each record");
+						+ "' has been forced from " + (maxPoll == null ? "unspecified" : maxPoll)
+						+ " to 1, to avoid having to seek after each record");
 			}
 			Map<String, Object> configs = new HashMap<>(suppliedConsumerFactory.getConfigurationProperties());
 			configs.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 1);