Class and Description |
---|
FlinkKafkaPartitioner
A
FlinkKafkaPartitioner wraps logic on how to partition records
across partitions of multiple Kafka topics. |
KafkaPartitioner
Deprecated.
This partitioner does not handle partitioning properly in the case of
multiple topics, and has been deprecated. Please use
FlinkKafkaPartitioner instead. |
Class and Description |
---|
FlinkKafkaPartitioner
A
FlinkKafkaPartitioner wraps logic on how to partition records
across partitions of multiple Kafka topics. |
KafkaPartitioner
Deprecated.
This partitioner does not handle partitioning properly in the case of
multiple topics, and has been deprecated. Please use
FlinkKafkaPartitioner instead. |
Class and Description |
---|
FlinkKafkaPartitioner
A
FlinkKafkaPartitioner wraps logic on how to partition records
across partitions of multiple Kafka topics. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.