cn.leancloud.kafka.consumer

Interface CommitPolicy<K,V>

public interface CommitPolicy<K,V>

Method Summary

Modifier and Type	Method and Description
void	addPendingRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
void	completeRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
Set<org.apache.kafka.common.TopicPartition>	partialCommit()
Set<org.apache.kafka.common.TopicPartition>	tryCommit(boolean noPendingRecords)

Method Detail

addPendingRecord

void addPendingRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)

completeRecord

void completeRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)

tryCommit

Set<org.apache.kafka.common.TopicPartition> tryCommit(boolean noPendingRecords)

partialCommit

Set<org.apache.kafka.common.TopicPartition> partialCommit()