Package org.apache.flink.streaming.connectors.kafka.partitioner

Class Summary

Class	Description
FlinkFixedPartitioner<T>	A partitioner ensuring that each internal Flink partition ends up in one Kafka partition.
FlinkKafkaDelegatePartitioner<T>	Deprecated Delegate for KafkaPartitioner, use FlinkKafkaPartitioner instead
FlinkKafkaPartitioner<T>	A FlinkKafkaPartitioner wraps logic on how to partition records across partitions of multiple Kafka topics.
KafkaPartitioner<T>	Deprecated This partitioner does not handle partitioning properly in the case of multiple topics, and has been deprecated.