4.17.0

Changelog

• #2490 - Bump camel.version from 4.3.0 to 4.4.0
• #2487 - fix: failure metadata creation when partition is null
• #2485 - Add build workflow to main branch to run tests with podman
• #2484 - Bump io.micrometer:micrometer-core from 1.12.2 to 1.12.3
• #2483 - Rename split io.smallrye.reactive.messaging.health package between ap…
• #2479 - Bump io.smallrye.config:smallrye-config from 3.5.3 to 3.5.4
• #2477 - Bump io.smallrye.config:smallrye-config from 3.5.2 to 3.5.3
• #2476 - Bump io.vertx:vertx-stack-depchain from 4.5.2 to 4.5.3
• #2475 - Bump org.slf4j:slf4j-reload4j from 2.0.11 to 2.0.12
• #2474 - Bump pulsar.version from 3.1.2 to 3.2.0
• #2471 - Fix pulsar consumer topic configuration check
• #2469 - Bump smallrye-common.version from 2.2.0 to 2.3.0
• #2464 - Bump io.vertx:vertx-stack-depchain from 4.5.1 to 4.5.2
• #2463 - Bump artemis.version from 2.31.2 to 2.32.0
• #2461 - Bump testcontainers.version from 1.19.3 to 1.19.4
• #2460 - Bump org.mockito:mockito-core from 5.9.0 to 5.10.0
• #2459 - Upgrade to Mutiny 2.5.5
• #2457 - #2456 - PulsarTrace - introducing mutable map

4.16.2

Changelog

• #2481 - Retrieve kafka config in places where Override connector config is used

4.16.1

Changelog

• #2478 - Avoid generating jandex index for health module

4.16.0

Changelog

• #2458 - Do not apply context decorator for emitter streams
• #2454 - Bump org.mockito:mockito-core from 5.8.0 to 5.9.0
• #2452 - Bump uk.org.webcompere:system-stubs-jupiter from 2.1.5 to 2.1.6
• #2451 - Bump io.smallrye.config:smallrye-config from 3.5.1 to 3.5.2
• #2450 - Bump jinja2 from 3.1.2 to 3.1.3 in /documentation
• #2449 - Bump io.micrometer:micrometer-core from 1.12.1 to 1.12.2
• #2447 - Bump org.slf4j:slf4j-reload4j from 2.0.10 to 2.0.11

4.15.0

Changelog

• #2446 - Improve backwards compatibility of new Message composition
• #2438 - RabbitMQ consumer arguments
• #2437 - Add support for the willMessageBytes method
• #2436 - RabbitMQ publisher confirms
• #2435 - Bump io.smallrye.config:smallrye-config from 3.5.0 to 3.5.1
• #2434 - Fix flaky Kafka concurrent tests
• #2433 - Bump pulsar.version from 3.1.1 to 3.1.2
• #2432 - Bump org.slf4j:slf4j-reload4j from 2.0.9 to 2.0.10
• #2431 - Bump io.smallrye.config:smallrye-config from 3.4.4 to 3.5.0
• #2430 - Bump jackson.version from 2.16.0 to 2.16.1
• #2429 - Bump org.jboss.logmanager:jboss-logmanager from 3.0.3.Final to 3.0.4.Final
• #2428 - Bump kotlin.version from 1.9.21 to 1.9.22

4.14.0

Changelog

• #2427 - Bump to Vert.x 4.5.1

4.13.0

Changelog

• #2413 - Minor fixes for Kafka request reply
• #2412 - In-memory connector docs update
• #2411 - Bump to Mutiny 2.5.3
• #2409 - Kafka Request Reply emitter and manual partition assignment
• #2408 - Bump io.micrometer:micrometer-core from 1.12.0 to 1.12.1
• #2406 - Kafka config override
• #2400 - Bump org.eclipse.microprofile.config:microprofile-config-api from 3.0.3 to 3.1
• #2399 - Bump kafka.version from 3.6.0 to 3.6.1
• #2398 - Bump org.mockito:mockito-core from 4.8.1 to 5.8.0
• #2397 - Remove deprecated Kafka metadata
• #2394 - Bump commons-io:commons-io from 2.15.0 to 2.15.1
• #2393 - Bump io.sundr:sundr-maven-plugin from 0.103.0 to 0.103.1
• #2391 - Bump io.smallrye:jandex-maven-plugin from 3.1.5 to 3.1.6
• #2390 - Bump io.sundr:sundr-maven-plugin from 0.101.3 to 0.103.0
• #2389 - Bump org.codehaus.mojo:build-helper-maven-plugin from 3.4.0 to 3.5.0

Breaking Changes

• method java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>> io.smallrye.reactive.messaging.mqtt.ReceivingMqttMessage::getNack() has been removed: Added Message metadata propagation
• method java.util.concurrent.CompletionStage<java.lang.Void> io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord<K, T>::ack() updated to method java.util.concurrent.CompletionStage<java.lang.Void> io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord<K, T>::ack(org.eclipse.microprofile.reactive.messaging.Metadata): Added Message metadata propagation
• method java.util.function.Supplier<java.util.concurrent.CompletionStage<java.lang.Void>> io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord<K, T>::getAck() has been removed: Added Message metadata propagation
• method java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>> io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord<K, T>::getNack() has been removed: Added Message metadata propagation
• method java.util.concurrent.CompletionStage<java.lang.Void> io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordBatch<K, T>::ack() updated to method java.util.concurrent.CompletionStage<java.lang.Void> io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordBatch<K, T>::ack(org.eclipse.microprofile.reactive.messaging.Metadata): Added Message metadata propagation
• method java.util.function.Supplier<java.util.concurrent.CompletionStage<java.lang.Void>> io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordBatch<K, T>::getAck() has been removed: Added Message metadata propagation
• method java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>> io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordBatch<K, T>::getNack() has been removed: Added Message metadata propagation
• method io.smallrye.mutiny.Uni<java.util.Map<java.lang.String, java.util.List<org.apache.kafka.common.PartitionInfo>>> io.smallrye.reactive.messaging.kafka.KafkaConsumer<K, V>::lisTopics() has been introduced: Added Message metadata propagation
• method io.smallrye.mutiny.Uni<java.util.Map<java.lang.String, java.util.List<org.apache.kafka.common.PartitionInfo>>> io.smallrye.reactive.messaging.kafka.KafkaConsumer<K, V>::lisTopics(java.time.Duration) has been introduced: Added Message metadata propagation
• method io.smallrye.mutiny.Uni<java.util.List<org.apache.kafka.common.PartitionInfo>> io.smallrye.reactive.messaging.kafka.KafkaConsumer<K, V>::partitionsFor(java.lang.String) has been introduced: Added Message metadata propagation
• parameter void io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord<K, T>::<init>(java.lang.String, K, T, java.time.Instant, int, org.apache.kafka.common.header.Headers, ===java.util.function.Supplier<java.util.concurrent.CompletionStage<java.lang.Void>>===, java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>>, org.eclipse.microprofile.reactive.messaging.Metadata) updated to parameter void io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord<K, T>::<init>(java.lang.String, K, T, java.time.Instant, int, org.apache.kafka.common.header.Headers, ===java.util.function.Function<org.eclipse.microprofile.reactive.messaging.Metadata, java.util.concurrent.CompletionStage<java.lang.Void>>===, java.util.function.BiFunction<java.lang.Throwable, org.eclipse.microprofile.reactive.messaging.Metadata, java.util.concurrent.CompletionStage<java.lang.Void>>, org.eclipse.microprofile.reactive.messaging.Metadata): Added Message metadata propagation
• parameter void io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord<K, T>::<init>(java.lang.String, K, T, java.time.Instant, int, org.apache.kafka.common.header.Headers, java.util.function.Supplier<java.util.concurrent.CompletionStage<java.lang.Void>>, ===java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>>===, org.eclipse.microprofile.reactive.messaging.Metadata) updated to parameter void io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord<K, T>::<init>(java.lang.String, K, T, java.time.Instant, int, org.apache.kafka.common.header.Headers, java.util.function.Function<org.eclipse.microprofile.reactive.messaging.Metadata, java.util.concurrent.CompletionStage<java.lang.Void>>, ===java.util.function.BiFunction<java.lang.Throwable, org.eclipse.microprofile.reactive.messaging.Metadata, java.util.concurrent.CompletionStage<java.lang.Void>>===, org.eclipse.microprofile.reactive.messaging.Metadata): Added Message metadata propagation
• method java.util.concurrent.CompletionStage<java.lang.Void> io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord<K, T>::ack() updated to method java.util.concurrent.CompletionStage<java.lang.Void> io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord<K, T>::ack(org.eclipse.microprofile.reactive.messaging.Metadata): Added Message metadata propagation
• method java.util.function.Supplier<java.util.concurrent.CompletionStage<java.lang.Void>> io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord<K, T>::getAck() has been removed: Added Message metadata propagation
• method java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>> io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord<K, T>::getNack() has been removed: Added Message metadata propagation
• class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata<K, T> has been removed: Removed deprecated IncomingKafkaRecordMetadata
• interface io.smallrye.reactive.messaging.kafka.KafkaMessageMetadata<K> has been removed: Removed deprecated KafkaMessageMetadata
• class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata<K> has been removed: Removed deprecated OutgoingKafkaRecordMetadata
• class io.smallrye.reactive.messaging.kafka.KafkaConnector updated to class io.smallrye.reactive.messaging.kafka.KafkaConnector: Added 'assign-seek' attribute for incoming channels
• method java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>> org.eclipse.microprofile.reactive.messaging.Message<T>::getNack() updated to method java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>> org.eclipse.microprofile.reactive.messaging.Message<T>::getNack(): Added Message metadata propagation, nack support no longer a SmallRye-only feature
• method java.util.concurrent.CompletionStage<java.lang.Void> org.eclipse.microprofile.reactive.messaging.Message<T>::nack(java.lang.Throwable) updated to method java.util.concurrent.CompletionStage<java.lang.Void> org.eclipse.microprofile.reactive.messaging.Message<T>::nack(java.lang.Throwable): Added Message metadata propagation, nack support no longer a SmallRye-only feature
• method <T> org.eclipse.microprofile.reactive.messaging.Message<T> org.eclipse.microprofile.reactive.messaging.Message<T>::of(T, org.eclipse.microprofile.reactive.messaging.Metadata, java.util.function.Supplier<java.util.concurrent.CompletionStage<java.lang.Void>>, java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>>) updated to method <T> org.eclipse.microprofile.reactive.messaging.Message<T> org.eclipse.microprofile.reactive.messaging.Message<T>::of(T, org.eclipse.microprofile.reactive.messaging.Metadata, java.util.function.Supplier<java.util.concurrent.CompletionStage<java.lang.Void>>, java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>>): Added Message metadata propagation, nack support no longer a SmallRye-only feature
• `method org.eclipse.microprofile.reactive.messaging.Message org.eclipse.microprofile.reactive.messaging.Message::withNack(java.util.function.Function<java.lang.Throwable,...

4.12.0

Changelog

• #2388 - Bump kotlin.version from 1.9.20 to 1.9.21
• #2386 - Bump com.opencsv:opencsv from 5.8 to 5.9
• #2385 - Definition exception for multiple different emitter configurations for a channel
• #2384 - Bump testcontainers.version from 1.19.2 to 1.19.3
• #2382 - Incoming channel concurrency
• #2381 - Bump org.codehaus.mojo:exec-maven-plugin from 3.1.0 to 3.1.1
• #2380 - Bump jackson.version from 2.15.3 to 2.16.0
• #2379 - Bump org.junit-pioneer:junit-pioneer from 2.1.0 to 2.2.0
• #2378 - Bump testcontainers.version from 1.19.1 to 1.19.2
• #2377 - Bump camel.version from 4.1.0 to 4.2.0
• #2376 - Bump io.micrometer:micrometer-core from 1.11.5 to 1.12.0
• #2375 - Update SmallRye Config to 3.4.4
• #2374 - Context-aware message dispatch on in-memory connector

Breaking Changes

• method org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.memory.InMemoryConnector::getPublisherBuilder(org.eclipse.microprofile.config.Config) has been removed: Migrated InMemoryConnector to InboundConnector
• method org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends org.eclipse.microprofile.reactive.messaging.Message<?>, java.lang.Void> io.smallrye.reactive.messaging.memory.InMemoryConnector::getSubscriberBuilder(org.eclipse.microprofile.config.Config) has been removed: Migrated InMemoryConnector to OutboundConnector
• class io.smallrye.reactive.messaging.memory.InMemoryConnector updated to class io.smallrye.reactive.messaging.memory.InMemoryConnector: Added connector attribute for dispatching messages on Vert.x context
• method io.smallrye.reactive.messaging.memory.InMemorySource<T> io.smallrye.reactive.messaging.memory.InMemorySource<T>::runOnVertxContext(boolean) has been introduced: Added method to InMemorySource for dispatching messages on Vert.x context

4.11.0

Changelog

• #2370 - Run emitter publisher decorators after registering the emitter to channel registry
• #2368 - Test flakiness : getMaxNumberOfEventLoop falls back to 1 if number of cores is 4.
• #2367 - Add 3.13.x to GitHub Actions
• #2363 - Removed java 20 branch and moved from 21-ea to 21
• #2362 - Connector contributor guide
• #2359 - Bump io.sundr:sundr-maven-plugin from 0.101.2 to 0.101.3
• #2357 - Seperate afterDeploymentValidation into two submethods
• #2355 - Bump kotlin.version from 1.9.10 to 1.9.20
• #2352 - Bump artemis.version from 2.31.1 to 2.31.2
• #2350 - Bump artemis.version from 2.31.0 to 2.31.1
• #2349 - Bump commons-io:commons-io from 2.14.0 to 2.15.0
• #2348 - Bump io.sundr:sundr-maven-plugin from 0.101.1 to 0.101.2
• #2345 - Bump pulsar.version from 3.1.0 to 3.1.1
• #2344 - Bump io.sundr:sundr-maven-plugin from 0.101.0 to 0.101.1
• #2343 - Bump org.apache.maven.plugins:maven-dependency-plugin from 3.6.0 to 3.6.1
• #2342 - Decorate emitters with PublisherDecorators
• #2341 - OTel upgrade to 1.31.0
• #2340 - Support metadata injection for interfaces
• #2336 - Let emitters report message metrics
• #2330 - Bump urllib3 from 2.0.6 to 2.0.7 in /documentation
• #2329 - Bump io.smallrye:smallrye-metrics from 4.0.0 to 5.1.0
• #2328 - Bump jackson.version from 2.15.2 to 2.15.3
• #2327 - Bump io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom-alpha from 1.28.0-alpha to 1.31.0-alpha
• #2325 - Bump io.strimzi:strimzi-test-container from 0.104.0 to 0.105.0
• #2324 - Bump camel.version from 4.0.1 to 4.1.0
• #2323 - Fix PauseResumeTest that became flaky because starting from Kafka 3.6.0
• #2321 - Bump io.micrometer:micrometer-core from 1.11.4 to 1.11.5
• #2320 - Documentation Typo
• #2319 - Bump io.smallrye:smallrye-parent from 41 to 42
• #2318 - Make queue.name default to channel name in RabbitMQ
• #2316 - Bump weld.version from 5.1.0.Final to 5.1.2.Final
• #2315 - Bump kafka.version from 3.5.1 to 3.6.0
• #2314 - Bump urllib3 from 2.0.4 to 2.0.6 in /documentation
• #2313 - Bump smallrye-common.version from 2.1.2 to 2.2.0
• #2312 - Bump io.smallrye.config:smallrye-config from 3.3.4 to 3.4.1
• #2311 - Bump testcontainers.version from 1.19.0 to 1.19.1
• #2310 - [trivial] Fixed typo in JavaDoc of PulsarMessages.java
• #2309 - Rabbitmq addresses config for cluster-mode
• #2308 - Bump commons-io:commons-io from 2.13.0 to 2.14.0
• #2307 - Update to Vert.x 4.4.5 and mutiny bindings 3.6.0
• #2306 - Added missing beans.xml and jandex plugin executions
• #2305 - Require 2 builds for codecov test coverage report

3.13.1

Changelog

• #2366 - Fix the synchronization protocol of the InternalChannelRegistry