org.thales.punch.kafka.api

Interface IRecordHandler<K,V>

Type Parameters:

K - the key type

V - the value type

All Known Implementing Classes:

ApplicationExitControllerImpl

public interface IRecordHandler<K,V>

This is your interface to receive Kafka records. Implement this, you will be invoked in turn when you call the IKafkaContinuousConsumer#nextMessages(int) method.

You receive records one at a time.

Author:

dimi

Method Summary

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

Method Detail

onReceive

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

Be notified upon the arrival of a record.

Parameters:

partition - the receiving partition. Use it to acknowledge or fail your records in the way you need.

record - the record

onTick

default void onTick(IPartition partition,
                    long nextOffsetToRead)

Be regularly called for each managed partition. This is called every second

Parameters:

partition - the partition

nextOffsetToRead - the first offset not already read from the partition

onPartitionAssigned

default void onPartitionAssigned(IPartition partition,
                                 org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata)

Notification of an assigned partition. You are guaranteed to be notified before receiving records.

Parameters:

partition - the assigned partition

offsetAndMetadata - the committed offsetAndMetadata

onPartitionRevoked

default void onPartitionRevoked(IPartition partition)

Notification of a revoked partition.

Parameters:

partition - the partition