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