Package io.confluent.parallelconsumer.internal

Class ConsumerOffsetCommitter<K,V>

java.lang.Object

io.confluent.parallelconsumer.internal.AbstractOffsetCommitter<K,V>

io.confluent.parallelconsumer.internal.ConsumerOffsetCommitter<K,V>

All Implemented Interfaces:

OffsetCommitter

public class ConsumerOffsetCommitter<K,V>
extends AbstractOffsetCommitter<K,V>
implements OffsetCommitter

Committer that uses the Kafka Consumer to commit either synchronously or asynchronously

See Also:

• ParallelConsumerOptions.CommitMode

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ConsumerOffsetCommitter.CommitRequest	Commit request message
static final class	ConsumerOffsetCommitter.CommitResponse	Commit response message, linked to a ConsumerOffsetCommitter.CommitRequest

Field Summary

Fields inherited from class io.confluent.parallelconsumer.internal.AbstractOffsetCommitter

consumerMgr, wm

Constructor Summary

Constructors

Constructor	Description
ConsumerOffsetCommitter(ConsumerManager<K,V> newConsumer, WorkManager<K,V> newWorkManager, ParallelConsumerOptions options)

Method Summary

Modifier and Type	Method	Description
void	claim()
protected void	commitOffsets(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToSend, org.apache.kafka.clients.consumer.ConsumerGroupMetadata groupMetadata)
boolean	isSync()
protected void	postCommit()

Methods inherited from class io.confluent.parallelconsumer.internal.AbstractOffsetCommitter

preAcquireWork, retrieveOffsetsAndCommit

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.parallelconsumer.internal.OffsetCommitter

retrieveOffsetsAndCommit

Constructor Details

ConsumerOffsetCommitter

public ConsumerOffsetCommitter(ConsumerManager<K,V> newConsumer,
 WorkManager<K,V> newWorkManager,
 ParallelConsumerOptions options)

Method Details

commitOffsets

protected void commitOffsets(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToSend,
 org.apache.kafka.clients.consumer.ConsumerGroupMetadata groupMetadata)

Specified by:

commitOffsets in class AbstractOffsetCommitter<K,V>

postCommit

protected void postCommit()

Overrides:

postCommit in class AbstractOffsetCommitter<K,V>

See Also:

• commit()

isSync

public boolean isSync()

claim

public void claim()