编写 kafka Partition 分配算法

package cn.itcast.storm.kafka; import kafka.producer.Partitioner; import kafka.utils.VerifiableProperties; import org.apache.log4j.Logger; public class MyLogPartitioner implements Partitioner {     pr

>>阅读原文<<