Loading...

XML

Word

Printable

Type: Feature Request
Resolution: Done
Priority: Major
Fix Version/s: 25.0.0.Beta1, 25.0.0.Final
Affects Version/s: None
Component/s: None
Labels:
None

Story Points:
5
Release Note Text:
Undefined
Git Pull Request:
https://github.com/wildfly/wildfly/pull/14619

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.

blocks

WFLY-15019 Full Support for RHOSAK Integration

Closed

WFLY-15016 Provide full Support for MicroProfile Reactive Messaging for AMQ Streams (Kafka) integration

Open

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

Assignee:: Kabir Khan

Reporter:: Kabir Khan

Votes:: 0 Vote for this issue

Watchers:: 1 Start watching this issue

Created:: 2021/06/24 8:44 AM

Updated:: 2022/09/09 7:14 AM

Resolved:: 2021/09/11 3:32 PM