Package org.thales.punch.kafka.api

Interface Summary

Interface	Description
IKafkaContinuousConsumer	The IKafkaContinuousConsumer is your main interface to continuously consume kafka topics.
IKafkaSettingsMapConsumer	The IKafkaSettingsMapConsumer is your main interface to read the latest settings map record from a punch admin topic or assignement topic.
IPartition	This interface lets you receive, acknowledge your records, in a way to let you achieve at-least/exactly once semantics.
IRecordHandler<K,V>	This is your interface to receive Kafka records.

Class Summary

Class	Description
KafkaContinuousConsumerBuilder<K,V>	The IKafkaContinuousConsumer builder.
KafkaSettingsMapConsumerBuilder	The IKafkaContinuousConsumer builder.

Enum Summary

Enum	Description
KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY	One of "earliest", "last_committed", "latest", "from_offset" or "from_timestamp".