Skip to content

4.5.0

Compare
Choose a tag to compare
@ozangunalp ozangunalp released this 20 Apr 13:32
· 1013 commits to main since this release
e0b96a0

Changelog

  • #2134 - Bump opentelemetry-instrumentation-bom-alpha from 1.24.0-alpha to 1.25.0-alpha
  • #2119 - Support stream processors on kafka message converters
  • #2118 - Bump opentelemetry-instrumentation-bom-alpha from 1.23.0-alpha to 1.24.0-alpha
  • #2113 - Upgrade Camel to 4.0.0-M2
  • #2106 - Decouple OpenTelemetry instrumenter

Breaking Changes

  • class io.smallrye.reactive.messaging.kafka.KafkaConnector updated to class io.smallrye.reactive.messaging.kafka.KafkaConnector: Added delayed-retry-topic to connector attributes
  • method io.smallrye.mutiny.Uni<java.util.Collection<org.apache.kafka.common.Node>> io.smallrye.reactive.messaging.kafka.KafkaAdmin::describeCluster() has been introduced: Options added to admin client methods
  • method io.smallrye.mutiny.Uni<java.util.Collection<org.apache.kafka.common.Node>> io.smallrye.reactive.messaging.kafka.KafkaAdmin::describeCluster(org.apache.kafka.clients.admin.DescribeClusterOptions) has been introduced: Options added to admin client methods
  • method io.smallrye.mutiny.Uni<java.util.Map<java.lang.String, org.apache.kafka.clients.admin.TopicDescription>> io.smallrye.reactive.messaging.kafka.KafkaAdmin::describeTopics(java.util.Collection<java.lang.String>) has been introduced: Options added to admin client methods
  • method io.smallrye.mutiny.Uni<java.util.Map<java.lang.String, org.apache.kafka.clients.admin.TopicDescription>> io.smallrye.reactive.messaging.kafka.KafkaAdmin::describeTopics(java.util.Collection<java.lang.String>, org.apache.kafka.clients.admin.DescribeTopicsOptions) has been introduced: Options added to admin client methods
  • method io.smallrye.mutiny.Uni<java.util.Set<java.lang.String>> io.smallrye.reactive.messaging.kafka.KafkaAdmin::listTopics(org.apache.kafka.clients.admin.ListTopicsOptions) has been introduced: Options added to admin client methods
  • method void io.smallrye.reactive.messaging.kafka.health.KafkaSourceHealth::<init>(io.smallrye.reactive.messaging.kafka.impl.KafkaSource<?, ?>, io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration, io.smallrye.reactive.messaging.kafka.impl.ReactiveKafkaConsumer<?, ?>) updated to method void io.smallrye.reactive.messaging.kafka.health.KafkaSourceHealth::<init>(io.smallrye.reactive.messaging.kafka.impl.KafkaSource<?, ?>, io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration, io.smallrye.reactive.messaging.kafka.impl.ReactiveKafkaConsumer<?, ?>, java.util.Set<java.lang.String>, java.util.regex.Pattern): Kafka Source Health checks for topic existence on startup
  • class io.smallrye.reactive.messaging.kafka.KafkaConnector updated to class io.smallrye.reactive.messaging.kafka.KafkaConnector: Added health-topic-verification-startup-disabled and health-topic-verification-readiness-disabled flags
  • field io.smallrye.reactive.messaging.kafka.companion.test.KafkaBrokerExtension.KAFKA_VERSION updated to field io.smallrye.reactive.messaging.kafka.companion.test.KafkaBrokerExtension.KAFKA_VERSION: Kafka broker version used for tests from 3.1.0 to 3.3.2