@Deprecated public class FlinkKafkaProducer<IN> extends FlinkKafkaProducer08<IN>
asyncException, callback, defaultTopicId, flushOnCheckpoint, KEY_DISABLE_METRICS, logFailuresOnly, partitioner, partitions, pendingRecords, pendingRecordsLock, producer, producerConfig, schema
Constructor and Description |
---|
FlinkKafkaProducer(String topicId,
KeyedSerializationSchema<IN> serializationSchema,
Properties producerConfig)
Deprecated.
|
FlinkKafkaProducer(String topicId,
KeyedSerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner customPartitioner)
Deprecated.
|
FlinkKafkaProducer(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig)
Deprecated.
|
FlinkKafkaProducer(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner customPartitioner)
Deprecated.
|
FlinkKafkaProducer(String brokerList,
String topicId,
KeyedSerializationSchema<IN> serializationSchema)
Deprecated.
|
FlinkKafkaProducer(String brokerList,
String topicId,
SerializationSchema<IN> serializationSchema)
Deprecated.
|
flush
checkErroneous, close, getKafkaProducer, getPropertiesFromBrokerList, invoke, numPendingRecords, open, restoreState, setFlushOnCheckpoint, setLogFailuresOnly, snapshotState
getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
@Deprecated public FlinkKafkaProducer(String brokerList, String topicId, SerializationSchema<IN> serializationSchema)
@Deprecated public FlinkKafkaProducer(String topicId, SerializationSchema<IN> serializationSchema, Properties producerConfig)
@Deprecated public FlinkKafkaProducer(String topicId, SerializationSchema<IN> serializationSchema, Properties producerConfig, KafkaPartitioner customPartitioner)
@Deprecated public FlinkKafkaProducer(String brokerList, String topicId, KeyedSerializationSchema<IN> serializationSchema)
@Deprecated public FlinkKafkaProducer(String topicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig)
@Deprecated public FlinkKafkaProducer(String topicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig, KafkaPartitioner customPartitioner)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.