Package | Description |
---|---|
io.smallrye.reactive.messaging.kafka | |
io.smallrye.reactive.messaging.kafka.api | |
io.smallrye.reactive.messaging.kafka.impl.ce |
Class and Description |
---|
IncomingKafkaRecordMetadata
Contains information about messages received from a channel backed by Kafka.
|
KafkaMessageMetadata
Common interface for
|
OutgoingKafkaRecordMetadata
Contains information the user can set to influence how messages are sent via Kafka.
|
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder
Builder to create
OutgoingKafkaRecordMetadata instances |
Class and Description |
---|
IncomingKafkaRecordMetadata
Contains information about messages received from a channel backed by Kafka.
|
KafkaMessageMetadata
Common interface for
|
OutgoingKafkaRecordMetadata
Contains information the user can set to influence how messages are sent via Kafka.
|
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder
Builder to create
OutgoingKafkaRecordMetadata instances |
Class and Description |
---|
OutgoingKafkaRecordMetadata
Contains information the user can set to influence how messages are sent via Kafka.
|
Copyright © 2018–2021 SmallRye. All rights reserved.