Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka | |
org.apache.flink.streaming.connectors.kafka.partitioner |
Modifier and Type | Field and Description |
---|---|
protected KafkaPartitioner<Row> |
KafkaTableSink.partitioner |
protected KafkaPartitioner<IN> |
FlinkKafkaProducerBase.partitioner
User-provided partitioner for assigning an object to a Kafka partition.
|
Modifier and Type | Method and Description |
---|---|
protected abstract FlinkKafkaProducerBase<Row> |
KafkaTableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
KafkaPartitioner<Row> partitioner)
Returns the version-specifid Kafka producer.
|
protected FlinkKafkaProducerBase<Row> |
Kafka09JsonTableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
KafkaPartitioner<Row> partitioner) |
protected FlinkKafkaProducerBase<Row> |
Kafka08JsonTableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
KafkaPartitioner<Row> partitioner) |
static <T> FlinkKafkaProducer010.FlinkKafkaProducer010Configuration<T> |
FlinkKafkaProducer010.writeToKafkaWithTimestamps(DataStream<T> inStream,
String topicId,
KeyedSerializationSchema<T> serializationSchema,
Properties producerConfig,
KafkaPartitioner<T> customPartitioner)
Creates a FlinkKafkaProducer for a given topic.
|
Constructor and Description |
---|
FlinkKafkaProducer(String topicId,
KeyedSerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner customPartitioner)
Deprecated.
|
FlinkKafkaProducer(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner customPartitioner)
Deprecated.
|
FlinkKafkaProducer010(String topicId,
KeyedSerializationSchema<T> serializationSchema,
Properties producerConfig,
KafkaPartitioner<T> customPartitioner)
Create Kafka producer
This constructor does not allow writing timestamps to Kafka, it follow approach (a) (see above)
|
FlinkKafkaProducer010(String topicId,
SerializationSchema<T> serializationSchema,
Properties producerConfig,
KafkaPartitioner<T> customPartitioner)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer08(String topicId,
KeyedSerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner<IN> customPartitioner)
The main constructor for creating a FlinkKafkaProducer.
|
FlinkKafkaProducer08(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner<IN> customPartitioner)
The main constructor for creating a FlinkKafkaProducer.
|
FlinkKafkaProducer09(String topicId,
KeyedSerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner<IN> customPartitioner)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer09(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner<IN> customPartitioner)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducerBase(String defaultTopicId,
KeyedSerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner<IN> customPartitioner)
The main constructor for creating a FlinkKafkaProducer.
|
Kafka08JsonTableSink(String topic,
Properties properties,
KafkaPartitioner<Row> partitioner)
Creates
KafkaTableSink for Kafka 0.8 |
Kafka09JsonTableSink(String topic,
Properties properties,
KafkaPartitioner<Row> partitioner)
Creates
KafkaTableSink for Kafka 0.9 |
KafkaJsonTableSink(String topic,
Properties properties,
KafkaPartitioner<Row> partitioner)
Creates KafkaJsonTableSink
|
KafkaTableSink(String topic,
Properties properties,
KafkaPartitioner<Row> partitioner)
Creates KafkaTableSink
|
Modifier and Type | Class and Description |
---|---|
class |
FixedPartitioner<T>
A partitioner ensuring that each internal Flink partition ends up in one Kafka partition.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.