org.apache.flink.streaming.connectors.kafka

Class FlinkKafkaConsumer082<T>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction<T>

org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase<T>

org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08<T>

org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082<T>

All Implemented Interfaces:

Serializable, Function, RichFunction, ResultTypeQueryable<T>, CheckpointListener, CheckpointedFunction, ParallelSourceFunction<T>, SourceFunction<T>

Deprecated.

Use FlinkKafkaConsumer08

@Deprecated
public class FlinkKafkaConsumer082<T>
extends FlinkKafkaConsumer08<T>

THIS CLASS IS DEPRECATED. Use FlinkKafkaConsumer08 instead.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.source.SourceFunction

SourceFunction.SourceContext<T>

Field Summary

Fields inherited from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08

DEFAULT_GET_PARTITIONS_RETRIES, GET_PARTITIONS_RETRIES_KEY

Fields inherited from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase

deserializer, KEY_DISABLE_METRICS, KEY_PARTITION_DISCOVERY_INTERVAL_MILLIS, LOG, MAX_NUM_PENDING_CHECKPOINTS, PARTITION_DISCOVERY_DISABLED

Constructor Summary

Constructors

Constructor and Description
FlinkKafkaConsumer082(String topic, DeserializationSchema<T> valueDeserializer, Properties props) Deprecated. Use FlinkKafkaConsumer08.FlinkKafkaConsumer08(String, DeserializationSchema, Properties)

Method Summary

Methods inherited from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08

createFetcher, createPartitionDiscoverer, fetchOffsetsWithTimestamp, getIsAutoCommitEnabled, validateZooKeeperConfig

Methods inherited from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase

assignTimestampsAndWatermarks, assignTimestampsAndWatermarks, cancel, close, disableFilterRestoredPartitionsWithSubscribedTopics, getProducedType, initializeState, notifyCheckpointComplete, open, run, setCommitOffsetsOnCheckpoints, setStartFromEarliest, setStartFromGroupOffsets, setStartFromLatest, setStartFromSpecificOffsets, setStartFromTimestamp, snapshotState

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkKafkaConsumer082

@Deprecated
public FlinkKafkaConsumer082(String topic,
                                         DeserializationSchema<T> valueDeserializer,
                                         Properties props)

Deprecated. Use FlinkKafkaConsumer08.FlinkKafkaConsumer08(String, DeserializationSchema, Properties)

THIS CONSTRUCTOR IS DEPRECATED. Use FlinkKafkaConsumer08 instead.