Uses of Class
org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaPartitioner

Packages that use FlinkKafkaPartitioner

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

Uses of FlinkKafkaPartitioner in org.apache.flink.streaming.connectors.kafka

Fields in org.apache.flink.streaming.connectors.kafka declared as FlinkKafkaPartitioner

Modifier and Type	Field and Description
protected FlinkKafkaPartitioner<IN>	FlinkKafkaProducerBase.flinkKafkaPartitioner User-provided partitioner for assigning an object to a Kafka partition for each topic.
protected FlinkKafkaPartitioner<Row>	KafkaTableSink.partitioner

Methods in org.apache.flink.streaming.connectors.kafka with parameters of type FlinkKafkaPartitioner

Modifier and Type	Method and Description
protected FlinkKafkaProducerBase<Row>	Kafka010JsonTableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, FlinkKafkaPartitioner<Row> partitioner)
protected FlinkKafkaProducerBase<Row>	Kafka09JsonTableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, FlinkKafkaPartitioner<Row> partitioner)
protected FlinkKafkaProducerBase<Row>	Kafka08JsonTableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, FlinkKafkaPartitioner<Row> partitioner)
protected abstract FlinkKafkaProducerBase<Row>	KafkaTableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, FlinkKafkaPartitioner<Row> partitioner) Returns the version-specific Kafka producer.
static <T> FlinkKafkaProducer010.FlinkKafkaProducer010Configuration<T>	FlinkKafkaProducer010.writeToKafkaWithTimestamps(DataStream<T> inStream, String topicId, KeyedSerializationSchema<T> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<T> customPartitioner) Deprecated. Use FlinkKafkaProducer010.FlinkKafkaProducer010(String, KeyedSerializationSchema, Properties, FlinkKafkaPartitioner) and call FlinkKafkaProducer010.setWriteTimestampToKafka(boolean).

Constructors in org.apache.flink.streaming.connectors.kafka with parameters of type FlinkKafkaPartitioner

Constructor and Description
FlinkKafkaProducer010(String topicId, KeyedSerializationSchema<T> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<T> customPartitioner) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer010(String topicId, SerializationSchema<T> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<T> customPartitioner) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer08(String topicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<IN> customPartitioner) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer08(String topicId, SerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<IN> customPartitioner) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer09(String topicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<IN> customPartitioner) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer09(String topicId, SerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<IN> customPartitioner) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducerBase(String defaultTopicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<IN> customPartitioner) The main constructor for creating a FlinkKafkaProducer.
Kafka010JsonTableSink(String topic, Properties properties, FlinkKafkaPartitioner<Row> partitioner) Creates KafkaTableSink to write table rows as JSON-encoded records to a Kafka 0.10 topic with custom partition assignment.
Kafka08JsonTableSink(String topic, Properties properties, FlinkKafkaPartitioner<Row> partitioner) Creates KafkaTableSink to write table rows as JSON-encoded records to a Kafka 0.8 topic with custom partition assignment.
Kafka09JsonTableSink(String topic, Properties properties, FlinkKafkaPartitioner<Row> partitioner) Creates KafkaTableSink to write table rows as JSON-encoded records to a Kafka 0.9 topic with custom partition assignment.
KafkaJsonTableSink(String topic, Properties properties, FlinkKafkaPartitioner<Row> partitioner) Creates KafkaJsonTableSink.
KafkaTableSink(String topic, Properties properties, FlinkKafkaPartitioner<Row> partitioner) Creates KafkaTableSink.

Constructor parameters in org.apache.flink.streaming.connectors.kafka with type arguments of type FlinkKafkaPartitioner

Constructor and Description
FlinkKafkaProducer011(String defaultTopicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig, Optional<FlinkKafkaPartitioner<IN>> customPartitioner) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer011(String defaultTopicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig, Optional<FlinkKafkaPartitioner<IN>> customPartitioner, FlinkKafkaProducer011.Semantic semantic, int kafkaProducersPoolSize) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer011(String topicId, SerializationSchema<IN> serializationSchema, Properties producerConfig, Optional<FlinkKafkaPartitioner<IN>> customPartitioner) Creates a FlinkKafkaProducer for a given topic.

Uses of FlinkKafkaPartitioner in org.apache.flink.streaming.connectors.kafka.partitioner

Subclasses of FlinkKafkaPartitioner in org.apache.flink.streaming.connectors.kafka.partitioner

Modifier and Type	Class and Description
class	FlinkFixedPartitioner<T> A partitioner ensuring that each internal Flink partition ends up in one Kafka partition.
class	FlinkKafkaDelegatePartitioner<T> Deprecated. Delegate for KafkaPartitioner, use FlinkKafkaPartitioner instead