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, received, terminate
-
-
-
-
Method Detail
-
handle
public <K,V> CompletionStage<Void> handle(IncomingKafkaRecord<K,V> record)
- Specified by:
handle
in interfaceKafkaCommitHandler
-
-