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/89567ebf Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/89567ebf Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/89567ebf Branch: refs/heads/support/nifi-0.6.x Commit: 89567ebfba3b6d4cf42b04aa981085b1f0e3564e Parents: 7561fa5 Author: Oleg Zhurakousky <[email protected]> Authored: Sat Mar 26 10:47:13 2016 -0400 Committer: Oleg Zhurakousky <[email protected]> Committed: Mon Apr 4 13:52:46 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/89567ebf/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);
