|
Extract And Move Method package adjustAutoCommitConfig(properties Properties, offsetCommitMode OffsetCommitMode) : void extracted from protected createFetcher(sourceContext SourceContext<T>, assignedPartitionsWithInitialOffsets Map<KafkaTopicPartition,Long>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, runtimeContext StreamingRuntimeContext, offsetCommitMode OffsetCommitMode, consumerMetricGroup MetricGroup, useMetrics boolean) : AbstractFetcher<T,?> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer & moved to class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Extract And Move Method package adjustAutoCommitConfig(properties Properties, offsetCommitMode OffsetCommitMode) : void extracted from protected createFetcher(sourceContext SourceContext<T>, assignedPartitionsWithInitialOffsets Map<KafkaTopicPartition,Long>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, runtimeContext StreamingRuntimeContext, offsetCommitMode OffsetCommitMode, consumerMetricGroup MetricGroup, useMetrics boolean) : AbstractFetcher<T,?> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 & moved to class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Extract And Move Method package adjustAutoCommitConfig(properties Properties, offsetCommitMode OffsetCommitMode) : void extracted from protected createFetcher(sourceContext SourceContext<T>, assignedPartitionsWithInitialOffsets Map<KafkaTopicPartition,Long>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, runtimeContext StreamingRuntimeContext, offsetCommitMode OffsetCommitMode, consumerMetricGroup MetricGroup, useMetrics boolean) : AbstractFetcher<T,?> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer010 & moved to class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |