@Deprecated public class FlinkKafkaConsumer082<T> extends FlinkKafkaConsumer08<T>
SourceFunction.SourceContext<T>
DEFAULT_GET_PARTITIONS_RETRIES, GET_PARTITIONS_RETRIES_KEY
allSubscribedPartitions, deserializer, KEY_DISABLE_METRICS, LOG, MAX_NUM_PENDING_CHECKPOINTS
Constructor and Description |
---|
FlinkKafkaConsumer082(String topic,
DeserializationSchema<T> valueDeserializer,
Properties props)
Deprecated.
|
createFetcher, getPartitionsForTopic, validateZooKeeperConfig
assignPartitions, assignTimestampsAndWatermarks, assignTimestampsAndWatermarks, cancel, close, getProducedType, logPartitionInfo, notifyCheckpointComplete, restoreState, run, setSubscribedPartitions, snapshotState
getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
@Deprecated public FlinkKafkaConsumer082(String topic, DeserializationSchema<T> valueDeserializer, Properties props)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.