Uses of Interface
org.thales.punch.kafka.api.IPartition

Packages that use IPartition

Package	Description
org.thales.punch.kafka.api
org.thales.punch.kafka.application
org.thales.punch.kafka.impl

Uses of IPartition in org.thales.punch.kafka.api

Methods in org.thales.punch.kafka.api with parameters of type IPartition

Modifier and Type	Method and Description
default void	IRecordHandler.onPartitionAssigned(IPartition partition, org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata) Notification of an assigned partition.
default void	IRecordHandler.onPartitionRevoked(IPartition partition) Notification of a revoked partition.
void	IRecordHandler.onReceive(IPartition partition, org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record) Be notified upon the arrival of a record.
default void	IRecordHandler.onTick(IPartition partition, long nextOffsetToRead) Be regularly called for each managed partition.

Uses of IPartition in org.thales.punch.kafka.application

Methods in org.thales.punch.kafka.application with parameters of type IPartition

Modifier and Type	Method and Description
void	ApplicationExitControllerImpl.onReceive(IPartition partition, org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)

Uses of IPartition in org.thales.punch.kafka.impl

Classes in org.thales.punch.kafka.impl that implement IPartition

Modifier and Type	Class and Description
class	AbstractPartition<K,V> Our IPartition abstract implementation.
class	OffsetTreePartitionImpl<K,V> Our IPartition implementation.
class	StandardPartitionImpl<K,V> Our IPartition implementation when consumer work with a straigth commit strategy, not requesting the fancy offset tree mode.