Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka | |
org.apache.flink.streaming.connectors.kafka.partitioner |
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. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.