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