Uses of Interface
org.apache.flink.streaming.connectors.kafka.internals.KafkaCommitCallback

Packages that use KafkaCommitCallback

Package	Description
org.apache.flink.streaming.connectors.kafka.internal
org.apache.flink.streaming.connectors.kafka.internals

Uses of KafkaCommitCallback in org.apache.flink.streaming.connectors.kafka.internal

Methods in org.apache.flink.streaming.connectors.kafka.internal with parameters of type KafkaCommitCallback

Modifier and Type	Method and Description
protected void	KafkaFetcher.doCommitInternalOffsetsToKafka(Map<KafkaTopicPartition,Long> offsets, KafkaCommitCallback commitCallback)
protected void	Kafka010Fetcher.doCommitInternalOffsetsToKafka(Map<KafkaTopicPartition,Long> offsets, KafkaCommitCallback commitCallback)

Uses of KafkaCommitCallback in org.apache.flink.streaming.connectors.kafka.internals

Methods in org.apache.flink.streaming.connectors.kafka.internals with parameters of type KafkaCommitCallback

Modifier and Type	Method and Description
void	AbstractFetcher.commitInternalOffsetsToKafka(Map<KafkaTopicPartition,Long> offsets, KafkaCommitCallback commitCallback) Commits the given partition offsets to the Kafka brokers (or to ZooKeeper for older Kafka versions).
protected abstract void	AbstractFetcher.doCommitInternalOffsetsToKafka(Map<KafkaTopicPartition,Long> offsets, KafkaCommitCallback commitCallback)