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

Packages that use IRecordHandler

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

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

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

Modifier and Type	Method and Description
IKafkaContinuousConsumer	KafkaContinuousConsumerBuilder.forReceiver(IRecordHandler<K,V> receiver)

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

Classes in org.thales.punch.kafka.application that implement IRecordHandler

Modifier and Type	Class and Description
class	ApplicationExitControllerImpl The exit controller watch a kafka topic and report to you these application you need to monitor to be told upon their wish to exit.

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

Methods in org.thales.punch.kafka.impl with parameters of type IRecordHandler

Modifier and Type	Method and Description
protected void	OffsetTreePartitionImpl.onReceive(IRecordHandler<K,V> receiver, org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record) Transfer the record to the receiver and keep track of current offset.
protected void	StandardPartitionImpl.onReceive(IRecordHandler<K,V> receiver, org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record) Transfer the record to the receiver.
protected abstract void	AbstractPartition.onReceive(IRecordHandler<K,V> receiver, org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
KafkaConsumerImpl<K,V>	KafkaConsumerImpl.setReceiver(IRecordHandler<K,V> receiver) PSet the receiver to handle incoming records.