You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2015/11/25 19:03:33 UTC
[3/4] nifi git commit: NIFI-1192: Removed some additional white space
NIFI-1192: Removed some additional white space
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/4fa2a713
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/4fa2a713
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/4fa2a713
Branch: refs/heads/master
Commit: 4fa2a713a2f4df901f0efa321db40682bb950ce9
Parents: 657885e
Author: Mark Payne <ma...@hotmail.com>
Authored: Wed Nov 25 12:57:06 2015 -0500
Committer: Mark Payne <ma...@hotmail.com>
Committed: Wed Nov 25 12:57:06 2015 -0500
----------------------------------------------------------------------
.../java/org/apache/nifi/processors/kafka/GetKafka.java | 11 ++++-------
1 file changed, 4 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/4fa2a713/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java
index 8f8d2e9..5e7a7ae 100644
--- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java
+++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java
@@ -223,8 +223,7 @@ public class GetKafka extends AbstractProcessor {
if (descriptor.isDynamic()) {
if (props.containsKey(descriptor.getName())) {
this.getLogger().warn("Overriding existing property '" + descriptor.getName() + "' which had value of '"
- + props.getProperty(descriptor.getName()) + "' with dynamically set value '"
- + entry.getValue() + "'.");
+ + props.getProperty(descriptor.getName()) + "' with dynamically set value '" + entry.getValue() + "'.");
}
props.setProperty(descriptor.getName(), entry.getValue());
}
@@ -251,20 +250,18 @@ public class GetKafka extends AbstractProcessor {
final Map<String, Integer> topicCountMap = new HashMap<>(1);
- int partitionCount = KafkaUtils.retrievePartitionCountForTopic(
- context.getProperty(ZOOKEEPER_CONNECTION_STRING).getValue(), context.getProperty(TOPIC).getValue());
+ int partitionCount = KafkaUtils.retrievePartitionCountForTopic(context.getProperty(ZOOKEEPER_CONNECTION_STRING).getValue(), context.getProperty(TOPIC).getValue());
int concurrentTaskToUse = context.getMaxConcurrentTasks();
if (context.getMaxConcurrentTasks() < partitionCount){
this.getLogger().warn("The amount of concurrent tasks '" + context.getMaxConcurrentTasks() + "' configured for "
+ "this processor is less than the amount of partitions '" + partitionCount + "' for topic '" + context.getProperty(TOPIC).getValue() + "'. "
- + "Consider making it equal to the amount of partition count for most efficient event consumption.");
+ + "Consider making it equal to the amount of partition count for most efficient event consumption.");
} else if (context.getMaxConcurrentTasks() > partitionCount){
concurrentTaskToUse = partitionCount;
this.getLogger().warn("The amount of concurrent tasks '" + context.getMaxConcurrentTasks() + "' configured for "
+ "this processor is greater than the amount of partitions '" + partitionCount + "' for topic '" + context.getProperty(TOPIC).getValue() + "'. "
- + "Therefore those tasks would never see a message. To avoid that the '" + partitionCount + "'(partition count) will be used to "
- + "consume events");
+ + "Therefore those tasks would never see a message. To avoid that the '" + partitionCount + "'(partition count) will be used to consume events");
}
topicCountMap.put(topic, concurrentTaskToUse);