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 types with arguments of type IncomingKafkaRecord

Modifier and Type	Method	Description
default <K,V> io.smallrye.mutiny.Uni<IncomingKafkaRecord<K,V>>	KafkaCommitHandler.received(IncomingKafkaRecord<K,V> record)
<K,V> io.smallrye.mutiny.Uni<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> io.smallrye.mutiny.Uni<IncomingKafkaRecord<K,V>>	KafkaCommitHandler.received(IncomingKafkaRecord<K,V> record)
<K,V> io.smallrye.mutiny.Uni<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, Metadata metadata)
<K,V> CompletionStage<Void>	KafkaFailStop.handle(IncomingKafkaRecord<K,V> record, Throwable reason, Metadata metadata)
<K,V> CompletionStage<Void>	KafkaFailureHandler.handle(IncomingKafkaRecord<K,V> record, Throwable reason, Metadata metadata)
<K,V> CompletionStage<Void>	KafkaIgnoreFailure.handle(IncomingKafkaRecord<K,V> record, Throwable reason, Metadata metadata)

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, boolean insideBatch)