Package io.smallrye.reactive.messaging.kafka.commit

Interface KafkaCommitHandler

All Known Implementing Classes:

KafkaIgnoreCommit, KafkaLatestCommit, KafkaThrottledLatestProcessedCommit

public interface KafkaCommitHandler

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	KafkaCommitHandler.Strategy

Method Summary

Modifier and Type	Method	Description
<K,V> CompletionStage<Void>	handle(IncomingKafkaRecord<K,V> record)
default void	partitionsAssigned(Collection<org.apache.kafka.common.TopicPartition> partitions)
default void	partitionsRevoked(Collection<org.apache.kafka.common.TopicPartition> partitions)
default <K,V> io.smallrye.mutiny.Uni<IncomingKafkaRecord<K,V>>	received(IncomingKafkaRecord<K,V> record)
default void	terminate(boolean graceful)

Method Detail

received

default <K,V> io.smallrye.mutiny.Uni<IncomingKafkaRecord<K,V>> received(IncomingKafkaRecord<K,V> record)

terminate

default void terminate(boolean graceful)

partitionsAssigned

default void partitionsAssigned(Collection<org.apache.kafka.common.TopicPartition> partitions)

partitionsRevoked

default void partitionsRevoked(Collection<org.apache.kafka.common.TopicPartition> partitions)

handle

<K,V> CompletionStage<Void> handle(IncomingKafkaRecord<K,V> record)