Package | Description |
---|---|
io.smallrye.reactive.messaging.kafka | |
io.smallrye.reactive.messaging.kafka.api |
Modifier and Type | Interface and Description |
---|---|
interface |
KafkaMessageMetadata<K>
Deprecated.
use
KafkaMessageMetadata instead |
Modifier and Type | Class and Description |
---|---|
class |
IncomingKafkaRecordMetadata<K,T>
Contains information about messages received from a channel backed by Kafka.
|
class |
OutgoingKafkaRecordMetadata<K>
Contains information the user can set to influence how messages are sent via Kafka.
|
Copyright © 2018–2021 SmallRye. All rights reserved.