Class | Description |
---|---|
FlinkFixedPartitioner<T> |
A partitioner ensuring that each internal Flink partition ends up in one Kafka partition.
|
FlinkKafkaPartitioner<T> |
A
FlinkKafkaPartitioner wraps logic on how to partition records across partitions of
multiple Kafka topics. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.