Clement Escoffier

Investigate io.smallrye.reactive.messaging.kafka.client.ReactiveKafkaConsumerTest#testGroupingRecordsByPartition

1

This test has been disabled as it was failing randomly on CI.

Investigate if we need outgoing retry in the Kafka connector

1

There is already a retry built-in in the Kafka producer. We may not need another one.

Reproducer: https://github.com/yholkamp/didactic-dollop

The script has a few bugs: * `antora` is not installed (and it needs the up to date antora) * The git repository URL is incorrect (must use https +...

MQTT Server - Add metadata support

1

The MQTT Server connector does not have inbound metadata support.

At the moment, the connector is creating `Message`. It would be great to allow injecting other types of payload such as: * JsonObject/ JsonArray is the content is a valid...

This could be integrated as in https://github.com/vert-x3/vertx-rx/blob/master/rx-java2/src/main/java/io/vertx/reactivex/core/RxHelper.java.

Fix NPE in VertxImpl when the threadFactory is accessed before its assignment

2

`createThreadFactory` references the `threadFactory` field. If a thread is created before the assignation, it leads to an NPE. By moving the assignment before the first call to `createThreadFactory`, we prevent...

Fix https://github.com/quarkusio/quarkus/issues/28053.

Implement the Redis Graph commands

1

These commands are marked as experimental, as we would need feedback before making them stable. The "Java" mapping I did (query response item) covers the various tests I tried, but...