----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/38153/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- Now it is possibel to implement a custom partitioner for Samza. Diffs ----- samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala 798033c samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala d84bf06 samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducer.scala c0c34bf samza-kafka/src/main/scala/org/apache/samza/system/kafka/partitioner/DefaultKafkaPartitioner.scala PRE-CREATION samza-kafka/src/main/scala/org/apache/samza/system/kafka/partitioner/KafkaPartitioner.scala PRE-CREATION samza-kafka/src/main/scala/org/apache/samza/system/kafka/partitioner/Murmur3KafkaPartitioner.scala PRE-CREATION samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtil.scala a7a095b samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemProducer.scala 39426d8 samza-kafka/src/test/scala/org/apache/samza/system/kafka/partitioner/TestMurmur3KafkaPartitioner.scala PRE-CREATION Diff: https://reviews.apache.org/r/38153/diff/ Testing ------- Thanks, József Márton Jung
