Class KafkaIgnoreCommit
- java.lang.Object
 - 
- io.smallrye.reactive.messaging.kafka.commit.KafkaIgnoreCommit
 
 
- 
- All Implemented Interfaces:
 KafkaCommitHandler
public class KafkaIgnoreCommit extends Object implements KafkaCommitHandler
Ignores an ACK and does not commit any offsets. This handler is the default when `enable.auto.commit` is `true`. When `enable.auto.commit` is `true` this strategy provides at-least-once delivery if the channel processes the message without performing any asynchronous processing. To use set `commit-strategy` to `ignore`. 
- 
- 
Nested Class Summary
- 
Nested classes/interfaces inherited from interface io.smallrye.reactive.messaging.kafka.commit.KafkaCommitHandler
KafkaCommitHandler.Strategy 
 - 
 
- 
Constructor Summary
Constructors Constructor Description KafkaIgnoreCommit() 
- 
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <K,V>
CompletionStage<Void>handle(IncomingKafkaRecord<K,V> record)- 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait 
- 
Methods inherited from interface io.smallrye.reactive.messaging.kafka.commit.KafkaCommitHandler
partitionsAssigned, partitionsRevoked, received, terminate 
 - 
 
 - 
 
- 
- 
Method Detail
- 
handle
public <K,V> CompletionStage<Void> handle(IncomingKafkaRecord<K,V> record)
- Specified by:
 handlein interfaceKafkaCommitHandler
 
 - 
 
 -