Package | Description |
---|---|
acme | |
io.smallrye.reactive.messaging.kafka |
Modifier and Type | Method and Description |
---|---|
CompletionStage<KafkaRecord<String,String>> |
Sender.send() |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
Receiver.consume(KafkaRecord<String,String> message) |
Modifier and Type | Interface and Description |
---|---|
interface |
KafkaMessage<K,T>
Deprecated.
Use
instead |
Modifier and Type | Class and Description |
---|---|
class |
IncomingKafkaRecord<K,T> |
class |
OutgoingKafkaRecord<K,T> |
Copyright © 2018–2021 SmallRye. All rights reserved.