NIFI-1684 This closes #302. fixed random partitioner initialization Signed-off-by: joewitt <[email protected]>
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9912f18d Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9912f18d Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9912f18d Branch: refs/heads/master Commit: 9912f18de54c6d8d7d7aaadd704199061e259330 Parents: 1292581 Author: Oleg Zhurakousky <[email protected]> Authored: Sat Mar 26 10:47:13 2016 -0400 Committer: joewitt <[email protected]> Committed: Tue Mar 29 09:56:08 2016 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/processors/kafka/PutKafka.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/9912f18d/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java index 44f04aa..6d17493 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java @@ -55,8 +55,6 @@ import org.apache.nifi.processor.exception.ProcessException; import org.apache.nifi.processor.io.InputStreamCallback; import org.apache.nifi.processor.util.StandardValidators; -import kafka.producer.DefaultPartitioner; - @InputRequirement(Requirement.INPUT_REQUIRED) @Tags({ "Apache", "Kafka", "Put", "Send", "Message", "PubSub" }) @CapabilityDescription("Sends the contents of a FlowFile as a message to Apache Kafka. The messages to send may be individual FlowFiles or may be delimited, using a " @@ -454,7 +452,7 @@ public class PutKafka extends AbstractProcessor { if (partitionStrategy.equalsIgnoreCase(ROUND_ROBIN_PARTITIONING.getValue())) { partitionerClass = Partitioners.RoundRobinPartitioner.class.getName(); } else if (partitionStrategy.equalsIgnoreCase(RANDOM_PARTITIONING.getValue())) { - partitionerClass = DefaultPartitioner.class.getName(); + partitionerClass = Partitioners.RandomPartitioner.class.getName(); } properties.setProperty("partitioner.class", partitionerClass);
