From 4daaefe4d948722a5906e14b0760b0e95ffb1eb7 Mon Sep 17 00:00:00 2001 From: Li Wang Date: Tue, 5 Apr 2016 20:32:24 -0400 Subject: [PATCH] revise a small typo on kafka error log --- .../integration/x/kafka/KafkaPartitionAllocator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/extensions/spring-xd-extension-kafka/src/main/java/org/springframework/integration/x/kafka/KafkaPartitionAllocator.java b/extensions/spring-xd-extension-kafka/src/main/java/org/springframework/integration/x/kafka/KafkaPartitionAllocator.java index 9420ff232..7608e16fe 100644 --- a/extensions/spring-xd-extension-kafka/src/main/java/org/springframework/integration/x/kafka/KafkaPartitionAllocator.java +++ b/extensions/spring-xd-extension-kafka/src/main/java/org/springframework/integration/x/kafka/KafkaPartitionAllocator.java @@ -109,7 +109,7 @@ public int compare(Partition partition1, Partition partition2) { partitionsMapByTopic.put(topic, partitions); maxPartitionCount = (partitions.size() > maxPartitionCount) ? partitions.size() : maxPartitionCount; } - Assert.isTrue(maxPartitionCount >= count, "Total module count should not be less than the maximum of " + + Assert.isTrue(maxPartitionCount >= count, "Total module count should not be more than the maximum of " + "partitions from the given topics"); if (topics.size() > 1) { Assert.isTrue(!StringUtils.hasText(partitionList), "Explicit partitions list isn't supported for " +