Uses of Class
io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

Packages that use IncomingKafkaRecord

Package	Description
io.smallrye.reactive.messaging.kafka.commit
io.smallrye.reactive.messaging.kafka.fault
io.smallrye.reactive.messaging.kafka.impl

Uses of IncomingKafkaRecord in io.smallrye.reactive.messaging.kafka.commit

Methods in io.smallrye.reactive.messaging.kafka.commit that return IncomingKafkaRecord

Modifier and Type	Method	Description
default <K,V> IncomingKafkaRecord<K,V>	KafkaCommitHandler.received(IncomingKafkaRecord<K,V> record)
<K,V> IncomingKafkaRecord<K,V>	KafkaThrottledLatestProcessedCommit.received(IncomingKafkaRecord<K,V> record)	Received a new record from Kafka.

Methods in io.smallrye.reactive.messaging.kafka.commit with parameters of type IncomingKafkaRecord

Modifier and Type	Method	Description
<K,V> CompletionStage<Void>	KafkaCommitHandler.handle(IncomingKafkaRecord<K,V> record)
<K,V> CompletionStage<Void>	KafkaIgnoreCommit.handle(IncomingKafkaRecord<K,V> record)
<K,V> CompletionStage<Void>	KafkaLatestCommit.handle(IncomingKafkaRecord<K,V> record)
<K,V> CompletionStage<Void>	KafkaThrottledLatestProcessedCommit.handle(IncomingKafkaRecord<K,V> record)	A message has been acknowledged.
default <K,V> IncomingKafkaRecord<K,V>	KafkaCommitHandler.received(IncomingKafkaRecord<K,V> record)
<K,V> IncomingKafkaRecord<K,V>	KafkaThrottledLatestProcessedCommit.received(IncomingKafkaRecord<K,V> record)	Received a new record from Kafka.

Uses of IncomingKafkaRecord in io.smallrye.reactive.messaging.kafka.fault

Methods in io.smallrye.reactive.messaging.kafka.fault with parameters of type IncomingKafkaRecord

Modifier and Type	Method	Description
<K,V> CompletionStage<Void>	KafkaDeadLetterQueue.handle(IncomingKafkaRecord<K,V> record, Throwable reason)
<K,V> CompletionStage<Void>	KafkaFailStop.handle(IncomingKafkaRecord<K,V> record, Throwable reason)
<K,V> CompletionStage<Void>	KafkaFailureHandler.handle(IncomingKafkaRecord<K,V> record, Throwable reason)
<K,V> CompletionStage<Void>	KafkaIgnoreFailure.handle(IncomingKafkaRecord<K,V> record, Throwable reason)

Uses of IncomingKafkaRecord in io.smallrye.reactive.messaging.kafka.impl

Methods in io.smallrye.reactive.messaging.kafka.impl that return types with arguments of type IncomingKafkaRecord

Modifier and Type	Method	Description
io.smallrye.mutiny.Multi<IncomingKafkaRecord<K,V>>	KafkaSource.getStream()

Methods in io.smallrye.reactive.messaging.kafka.impl with parameters of type IncomingKafkaRecord

Modifier and Type	Method	Description
void	KafkaSource.incomingTrace(IncomingKafkaRecord<K,V> kafkaRecord)