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 " +