Uses of Interface
io.smallrye.reactive.messaging.kafka.KafkaRecord

Packages that use KafkaRecord

Package	Description
acme
io.smallrye.reactive.messaging.kafka

Uses of KafkaRecord in acme

Methods in acme that return types with arguments of type KafkaRecord

Modifier and Type	Method	Description
CompletionStage<KafkaRecord<String,String>>	Sender.send()

Methods in acme with parameters of type KafkaRecord

Modifier and Type	Method	Description
CompletionStage<Void>	Receiver.consume(KafkaRecord<String,String> message)

Uses of KafkaRecord in io.smallrye.reactive.messaging.kafka

Subinterfaces of KafkaRecord in io.smallrye.reactive.messaging.kafka

Modifier and Type	Interface	Description
interface	KafkaMessage<K,T>	Deprecated. Use instead

Classes in io.smallrye.reactive.messaging.kafka that implement KafkaRecord

Modifier and Type	Class	Description
class	IncomingKafkaRecord<K,T>
class	OutgoingKafkaRecord<K,T>

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

Modifier and Type	Method	Description
Map<org.apache.kafka.common.TopicPartition,KafkaRecord<K,T>>	IncomingKafkaRecordBatch.getLatestOffsetRecords()
Map<org.apache.kafka.common.TopicPartition,KafkaRecord<K,T>>	KafkaRecordBatch.getLatestOffsetRecords()
List<KafkaRecord<K,T>>	IncomingKafkaRecordBatch.getRecords()
List<KafkaRecord<K,T>>	KafkaRecordBatch.getRecords()
Iterator<KafkaRecord<K,T>>	IncomingKafkaRecordBatch.iterator()