Package org.thales.punch.kafka.impl

Class Summary

Class	Description
AbstractPartition<K,V>	Our IPartition abstract implementation.
KafkaConsumerImpl<K,V>	The IKafkaReader implementation.
KafkaSecurityUtil
MonitoredPartition	This class holds per partition metrics.
OffsetTree	An OffsetTree is a sorted set of longs to manage Kafka offset.
OffsetTreePartitionImpl<K,V>	Our IPartition implementation.
StandardPartitionImpl<K,V>	Our IPartition implementation when consumer work with a straigth commit strategy, not requesting the fancy offset tree mode.