Uses of Class
org.thales.punch.kafka.impl.KafkaConsumerImpl

Packages that use KafkaConsumerImpl

Package	Description
org.thales.punch.kafka.impl

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

Methods in org.thales.punch.kafka.impl that return KafkaConsumerImpl

Modifier and Type	Method and Description
KafkaConsumerImpl<K,V>	KafkaConsumerImpl.setMetricContext(org.thales.punch.libraries.metrics.api.IMetricContext metricContext) Provide a metric context to this consumer
KafkaConsumerImpl<K,V>	KafkaConsumerImpl.setOffsetTree(boolean useOffsetTree) Request an offset tree t=strategy.
KafkaConsumerImpl<K,V>	KafkaConsumerImpl.setReceiver(IRecordHandler<K,V> receiver) PSet the receiver to handle incoming records.
KafkaConsumerImpl<K,V>	KafkaConsumerImpl.setSmartFailureHandling(boolean smartFailureHandling) Set the smart failure handling.
KafkaConsumerImpl<K,V>	KafkaConsumerImpl.setTickInterval(long tickInterval) Set the tick interval.