Details
-
Feature Request
-
Status: Closed (View Workflow)
-
Major
-
Resolution: Done
-
None
-
None
-
None
Description
This needs to use https://github.com/smallrye/smallrye-reactive-messaging/blob/3.0.0/smallrye-reactive-messaging-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/KafkaMessageMetadata.java which in turn uses the upcoming (probably RM spec 2.1) Message.getMetadata() method.
It allows you to specify the key, partition etc. the Kafka messages should be sent to, allowing you finer-grained control of them.
Attachments
Issue Links
- blocks
-
WFLY-15016 Provide full Support for MicroProfile Reactive Messaging for AMQ Streams (Kafka) integration
-
- Pull Request Sent
-
-
WFLY-15019 Full Support for RHOSAK Integration
-
- Pull Request Sent
-
- is related to
-
WFLY-15299 Review the smallrye-reactive-messaging-kafka-api module visibility
-
- Closed
-
-
WFLY-15300 Review the kafka-clients and vertx-kafka-client module
-
- Closed
-