| 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.