Skip to content

4.13.0
Compare
Choose a tag to compare
@ozangunalp ozangunalp released this 15 Dec 19:14
· 696 commits to main since this release
4.13.0
839f9bc
This commit was signed with the committer’s verified signature.
ozangunalp Ozan Gunalp
GPG key ID: D2934811B90CB810
Learn about vigilant mode.

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<T> org.eclipse.microprofile.reactive.messaging.Message<T>::withNack(java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>>) updated to method org.eclipse.microprofile.reactive.messaging.Message<T> org.eclipse.microprofile.reactive.messaging.Message<T>::withNack(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 java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>> org.eclipse.microprofile.reactive.messaging.Message<T>::getNack() @ io.smallrye.reactive.messaging.TargetedMessages.Default 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() @ io.smallrye.reactive.messaging.TargetedMessages.Default: 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) @ io.smallrye.reactive.messaging.TargetedMessages.Default updated to method java.util.concurrent.CompletionStage<java.lang.Void> org.eclipse.microprofile.reactive.messaging.Message<T>::nack(java.lang.Throwable) @ io.smallrye.reactive.messaging.TargetedMessages.Default: 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>>) @ io.smallrye.reactive.messaging.TargetedMessages.Default 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>>) @ io.smallrye.reactive.messaging.TargetedMessages.Default: Added Message metadata propagation, nack support no longer a SmallRye-only feature
  • method org.eclipse.microprofile.reactive.messaging.Message<T> org.eclipse.microprofile.reactive.messaging.Message<T>::withNack(java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>>) @ io.smallrye.reactive.messaging.TargetedMessages.Default updated to method org.eclipse.microprofile.reactive.messaging.Message<T> org.eclipse.microprofile.reactive.messaging.Message<T>::withNack(java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>>) @ io.smallrye.reactive.messaging.TargetedMessages.Default: Added Message metadata propagation, nack support no longer a SmallRye-only feature
  • method java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>> org.eclipse.microprofile.reactive.messaging.Message<T>::getNack() @ io.smallrye.reactive.messaging.TargetedMessages 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() @ io.smallrye.reactive.messaging.TargetedMessages: 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) @ io.smallrye.reactive.messaging.TargetedMessages updated to method java.util.concurrent.CompletionStage<java.lang.Void> org.eclipse.microprofile.reactive.messaging.Message<T>::nack(java.lang.Throwable) @ io.smallrye.reactive.messaging.TargetedMessages: 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>>) @ io.smallrye.reactive.messaging.TargetedMessages 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>>) @ io.smallrye.reactive.messaging.TargetedMessages: Added Message metadata propagation, nack support no longer a SmallRye-only feature
  • method org.eclipse.microprofile.reactive.messaging.Message<T> org.eclipse.microprofile.reactive.messaging.Message<T>::withNack(java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>>) @ io.smallrye.reactive.messaging.TargetedMessages updated to method org.eclipse.microprofile.reactive.messaging.Message<T> org.eclipse.microprofile.reactive.messaging.Message<T>::withNack(java.util.function.Function<java.lang.Throwable, java.util.concurrent.CompletionStage<java.lang.Void>>) @ io.smallrye.reactive.messaging.TargetedMessages: Added Message metadata propagation, nack support no longer a SmallRye-only feature
Assets 2
Loading