|
Rename Method public commitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>, commitCallback KafkaCommitCallback) : void renamed to protected doCommitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>, commitCallback KafkaCommitCallback) : void in class org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher |
From |
To |
|
Rename Method public abstract commitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>, commitCallback KafkaCommitCallback) : void renamed to protected abstract doCommitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>, commitCallback KafkaCommitCallback) : void in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher |
From |
To |
|
Rename Method public commitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>, commitCallback KafkaCommitCallback) : void renamed to protected doCommitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>, commitCallback KafkaCommitCallback) : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher |
From |
To |