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