From 4e0107b4d200e8f8b5f942d9fd1a1419af137a03 Mon Sep 17 00:00:00 2001 From: Ilayaperumal Gopinathan Date: Tue, 16 May 2017 22:28:25 +0530 Subject: [PATCH] Minor polishing --- .../kafka/provisioning/KafkaTopicProvisioner.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java b/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java index 9d0b65af1..a1e9b3dd6 100644 --- a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java +++ b/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java @@ -188,7 +188,7 @@ public class KafkaTopicProvisioner implements ProvisioningProvider 1 ? " have " : " has ") + "been found instead." - + "There will be " + (effectivePartitionCount - partitionSize) + " consumers"); + + "There will be " + (effectivePartitionCount - partitionSize) + " idle consumers"); } else { throw new ProvisioningException("The number of expected partitions was: " + partitionCount + ", but " @@ -250,16 +250,16 @@ public class KafkaTopicProvisioner implements ProvisioningProvider partitions = callable.call(); // do a sanity check on the partition set int partitionSize = partitions.size(); - if (partitions.size() < partitionCount) { + if (partitionSize < partitionCount) { if (tolerateLowerPartitionsOnBroker) { logger.warn("The number of expected partitions was: " + partitionCount + ", but " + partitionSize + (partitionSize > 1 ? " have " : " has ") + "been found instead." - + "There will be " + (partitionCount - partitionSize) + "idle consumers"); + + "There will be " + (partitionCount - partitionSize) + " idle consumers"); } else { throw new IllegalStateException("The number of expected partitions was: " - + partitionCount + ", but " + partitions.size() - + (partitions.size() > 1 ? " have " : " has ") + "been found instead"); + + partitionCount + ", but " + partitionSize + + (partitionSize > 1 ? " have " : " has ") + "been found instead"); } } return partitions;