From 6cb101b56efa17e4a0cfd94347607c3fcc00bed6 Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Wed, 1 Jul 2026 21:27:54 +0000 Subject: [PATCH 1/4] Bump io.debezium:debezium-bom from 3.5.2.Final to 3.6.0.Final Bumps [io.debezium:debezium-bom](https://github.com/debezium/debezium) from 3.5.2.Final to 3.6.0.Final. - [Changelog](https://github.com/debezium/debezium/blob/main/CHANGELOG.md) - [Commits](https://github.com/debezium/debezium/compare/v3.5.2.Final...v3.6.0.Final) --- updated-dependencies: - dependency-name: io.debezium:debezium-bom dependency-version: 3.6.0.Final dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index 05d162b7947..6fed3f0c871 100644 --- a/pom.xml +++ b/pom.xml @@ -46,7 +46,7 @@ camel-${camel.major.minor}.x 4.21.0 1.4.1 - 3.5.2.Final + 3.6.0.Final ${rocketmq-version} 10.0.0 3.21.0 From 6a1310e07b59cccbb3721262de6ed1c9c36f9d47 Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Wed, 1 Jul 2026 21:35:49 +0000 Subject: [PATCH 2/4] Auto generated changes for dependabot commit 55f731e4964d28bc60f2cc1ae0cbc15aa8ab9e30 --- .../src/main/generated/flattened-full-pom.xml | 170 ++++++++++++------ .../main/generated/flattened-reduced-pom.xml | 53 ++++-- .../flattened-reduced-verbose-pom.xml | 53 ++++-- 3 files changed, 181 insertions(+), 95 deletions(-) diff --git a/poms/bom/src/main/generated/flattened-full-pom.xml b/poms/bom/src/main/generated/flattened-full-pom.xml index e0d3687d7f4..e72ef17a404 100644 --- a/poms/bom/src/main/generated/flattened-full-pom.xml +++ b/poms/bom/src/main/generated/flattened-full-pom.xml @@ -24827,17 +24827,22 @@ com.fasterxml.jackson.core jackson-datatype-jdk8 - 2.19.0 + 2.21.2 + + + org.hibernate + hibernate-agroal + 7.2.6.Final org.apache.kafka connect-file - 4.1.2 + 4.3.0 org.apache.kafka kafka_2.13 - 4.1.2 + 4.3.0 test @@ -24853,12 +24858,12 @@ io.apicurio apicurio-registry-utils-converter - 2.6.13.Final + 3.2.5 io.debezium mysql-binlog-connector-java - 0.40.6 + 0.41.0 mil.nga @@ -24868,7 +24873,7 @@ com.oracle.instantclient xstreams - 21.15.0.0 + 23.26.1.0.0 com.ibm.informix @@ -24943,13 +24948,43 @@ org.infinispan infinispan-core - 15.2.1.Final + 16.1.3 + + + net.openhft + chronicle-queue + 2026.2 org.apache.rocketmq rocketmq-tools 5.2.0 + + org.rocksdb + rocksdbjni + 9.8.4 + + + ai.docling + docling-serve-api + 0.5.0 + + + ai.docling + docling-serve-client + 0.5.0 + + + com.datadoghq + sketches-java + 0.8.2 + + + ai.docling + docling-testcontainers + 0.5.0 + org.assertj assertj-core @@ -24990,263 +25025,284 @@ opentelemetry-agent-for-testing 2.24.0-alpha + + com.tngtech.archunit + archunit-junit5 + 1.4.2 + io.debezium debezium-api - 3.5.2.Final + 3.6.0.Final io.debezium debezium-util - 3.5.2.Final + 3.6.0.Final io.debezium debezium-config - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-common - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connect-plugins - 3.5.2.Final + 3.6.0.Final io.debezium debezium-sink - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-jdbc - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-kafka - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-azure-blob - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-s3 - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-file - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-redis - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-configmap - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-tests - 3.5.2.Final + 3.6.0.Final + + + io.debezium + debezium-storage-chronicle-queue + 3.6.0.Final io.debezium debezium-scripting - 3.5.2.Final + 3.6.0.Final io.debezium debezium-scripting-languages - 3.5.2.Final + 3.6.0.Final pom io.debezium debezium-embedded - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-jdbc - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-postgres - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-postgres-test - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-mysql - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-mariadb - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-binlog - 3.5.2.Final + 3.6.0.Final io.debezium debezium-ddl-parser - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-mongodb - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-sqlserver - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-oracle - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-db2 - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-spanner - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-vitess - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-informix - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-ibmi - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-cockroachdb - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-cassandra-3 - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-cassandra-4 - 3.5.2.Final + 3.6.0.Final io.debezium debezium-testing-testcontainers - 3.5.2.Final + 3.6.0.Final + + + io.debezium + debezium-archunit + 3.6.0.Final io.debezium debezium-schema-generator - 3.5.2.Final + 3.6.0.Final io.debezium debezium-quarkus-outbox - 3.5.2.Final + 3.6.0.Final io.debezium debezium-quarkus-outbox-deployment - 3.5.2.Final + 3.6.0.Final io.debezium debezium-ai-embeddings - 3.5.2.Final + 3.6.0.Final io.debezium debezium-openlineage-api - 3.5.2.Final + 3.6.0.Final io.debezium debezium-openlineage-core - 3.5.2.Final + 3.6.0.Final + + + io.debezium + debezium-util + 3.6.0.Final + test-jar io.debezium debezium-connector-common - 3.5.2.Final + 3.6.0.Final test-jar io.debezium debezium-connect-plugins - 3.5.2.Final + 3.6.0.Final test-jar io.debezium debezium-embedded - 3.5.2.Final + 3.6.0.Final test-jar io.debezium debezium-connector-mysql - 3.5.2.Final + 3.6.0.Final test-jar io.debezium debezium-connector-binlog - 3.5.2.Final + 3.6.0.Final test-jar io.debezium debezium-ai-embeddings - 3.5.2.Final + 3.6.0.Final test-jar io.debezium debezium-openlineage-api - 3.5.2.Final + 3.6.0.Final test-jar io.debezium debezium-openlineage-core - 3.5.2.Final + 3.6.0.Final test-jar diff --git a/poms/bom/src/main/generated/flattened-reduced-pom.xml b/poms/bom/src/main/generated/flattened-reduced-pom.xml index b7072295a74..7dea99c1d31 100644 --- a/poms/bom/src/main/generated/flattened-reduced-pom.xml +++ b/poms/bom/src/main/generated/flattened-reduced-pom.xml @@ -47,6 +47,16 @@ + + ai.docling + docling-serve-api + 0.5.0 + + + ai.docling + docling-serve-client + 0.5.0 + ca.uhn.hapi hapi-base @@ -295,6 +305,11 @@ azure-xml 1.2.0 + + com.datadoghq + sketches-java + 0.8.2 + com.datastax.oss native-protocol @@ -792,92 +807,92 @@ io.debezium debezium-api - 3.5.2.Final + 3.6.0.Final io.debezium debezium-config - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connect-plugins - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-binlog - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-common - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-mongodb - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-mysql - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-oracle - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-postgres - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-sqlserver - 3.5.2.Final + 3.6.0.Final io.debezium debezium-ddl-parser - 3.5.2.Final + 3.6.0.Final io.debezium debezium-embedded - 3.5.2.Final + 3.6.0.Final io.debezium debezium-openlineage-api - 3.5.2.Final + 3.6.0.Final io.debezium debezium-sink - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-file - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-kafka - 3.5.2.Final + 3.6.0.Final io.debezium debezium-util - 3.5.2.Final + 3.6.0.Final io.debezium mysql-binlog-connector-java - 0.40.6 + 0.41.0 io.dropwizard.metrics @@ -8784,7 +8799,7 @@ org.apache.kafka connect-file - 4.1.2 + 4.3.0 org.apache.kafka diff --git a/poms/bom/src/main/generated/flattened-reduced-verbose-pom.xml b/poms/bom/src/main/generated/flattened-reduced-verbose-pom.xml index 3146b0e5fa4..892afa28047 100644 --- a/poms/bom/src/main/generated/flattened-reduced-verbose-pom.xml +++ b/poms/bom/src/main/generated/flattened-reduced-verbose-pom.xml @@ -47,6 +47,16 @@ + + ai.docling + docling-serve-api + 0.5.0 + + + ai.docling + docling-serve-client + 0.5.0 + ca.uhn.hapi hapi-base @@ -295,6 +305,11 @@ azure-xml 1.2.0 + + com.datadoghq + sketches-java + 0.8.2 + com.datastax.oss native-protocol @@ -792,92 +807,92 @@ io.debezium debezium-api - 3.5.2.Final + 3.6.0.Final io.debezium debezium-config - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connect-plugins - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-binlog - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-common - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-mongodb - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-mysql - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-oracle - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-postgres - 3.5.2.Final + 3.6.0.Final io.debezium debezium-connector-sqlserver - 3.5.2.Final + 3.6.0.Final io.debezium debezium-ddl-parser - 3.5.2.Final + 3.6.0.Final io.debezium debezium-embedded - 3.5.2.Final + 3.6.0.Final io.debezium debezium-openlineage-api - 3.5.2.Final + 3.6.0.Final io.debezium debezium-sink - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-file - 3.5.2.Final + 3.6.0.Final io.debezium debezium-storage-kafka - 3.5.2.Final + 3.6.0.Final io.debezium debezium-util - 3.5.2.Final + 3.6.0.Final io.debezium mysql-binlog-connector-java - 0.40.6 + 0.41.0 io.dropwizard.metrics @@ -8784,7 +8799,7 @@ org.apache.kafka connect-file - 4.1.2 + 4.3.0 org.apache.kafka From ca696c3692fcc9ea368562e6e1d813b934e45bd1 Mon Sep 17 00:00:00 2001 From: James Netherton Date: Thu, 2 Jul 2026 07:57:40 +0100 Subject: [PATCH 3/4] Adapt Debezium native support for 3.6.0.Final --- .../deployment/DebeziumSupportProcessor.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/extensions-support/debezium/deployment/src/main/java/org/apache/camel/quarkus/support/debezium/deployment/DebeziumSupportProcessor.java b/extensions-support/debezium/deployment/src/main/java/org/apache/camel/quarkus/support/debezium/deployment/DebeziumSupportProcessor.java index 14075d7cd1b..6554629c24b 100644 --- a/extensions-support/debezium/deployment/src/main/java/org/apache/camel/quarkus/support/debezium/deployment/DebeziumSupportProcessor.java +++ b/extensions-support/debezium/deployment/src/main/java/org/apache/camel/quarkus/support/debezium/deployment/DebeziumSupportProcessor.java @@ -18,6 +18,7 @@ import java.util.function.BooleanSupplier; +import io.debezium.connector.base.DefaultQueueProvider; import io.debezium.connector.common.BaseSourceTask; import io.debezium.embedded.async.ConvertingAsyncEngineBuilderFactory; import io.debezium.engine.DebeziumEngine; @@ -38,9 +39,9 @@ import io.debezium.snapshot.mode.ConfigurationBasedSnapshotter; import io.debezium.snapshot.mode.InitialOnlySnapshotter; import io.debezium.snapshot.mode.InitialSnapshotter; -import io.debezium.snapshot.mode.NeverSnapshotter; import io.debezium.snapshot.mode.NoDataSnapshotter; import io.debezium.snapshot.mode.RecoverySnapshotter; +import io.debezium.snapshot.mode.WhenNeededNoDataSnapshotter; import io.debezium.snapshot.mode.WhenNeededSnapshotter; import io.debezium.snapshot.spi.SnapshotLock; import io.debezium.storage.file.history.FileSchemaHistory; @@ -105,7 +106,8 @@ void reflectiveClasses(CombinedIndexBuildItem combinedIndex, BuildProducer re resources.produce(new NativeImageResourceBuildItem("META-INF/services/io.debezium.snapshot.spi.SnapshotLock")); resources.produce(new NativeImageResourceBuildItem("META-INF/services/io.debezium.snapshot.spi.SnapshotQuery")); + resources.produce(new NativeImageResourceBuildItem("META-INF/services/io.debezium.connector.base.QueueProvider")); resources .produce(new NativeImageResourceBuildItem("META-INF/services/org.apache.kafka.connect.source.SourceConnector")); } From 8f67cf6683369b9bed16845c39db32f9fd1f0473 Mon Sep 17 00:00:00 2001 From: James Netherton Date: Tue, 21 Jul 2026 08:02:35 +0100 Subject: [PATCH 4/4] Remove redundant Debezium workarounds for kafka-clients 4.2.0 compatibility Fixes #8530 --- .../deployment/DebeziumSupportProcessor.java | 101 ------------------ 1 file changed, 101 deletions(-) diff --git a/extensions-support/debezium/deployment/src/main/java/org/apache/camel/quarkus/support/debezium/deployment/DebeziumSupportProcessor.java b/extensions-support/debezium/deployment/src/main/java/org/apache/camel/quarkus/support/debezium/deployment/DebeziumSupportProcessor.java index 6554629c24b..33fccdf8a1b 100644 --- a/extensions-support/debezium/deployment/src/main/java/org/apache/camel/quarkus/support/debezium/deployment/DebeziumSupportProcessor.java +++ b/extensions-support/debezium/deployment/src/main/java/org/apache/camel/quarkus/support/debezium/deployment/DebeziumSupportProcessor.java @@ -16,8 +16,6 @@ */ package org.apache.camel.quarkus.support.debezium.deployment; -import java.util.function.BooleanSupplier; - import io.debezium.connector.base.DefaultQueueProvider; import io.debezium.connector.common.BaseSourceTask; import io.debezium.embedded.async.ConvertingAsyncEngineBuilderFactory; @@ -48,26 +46,18 @@ import io.quarkus.arc.deployment.AdditionalBeanBuildItem; import io.quarkus.deployment.annotations.BuildProducer; import io.quarkus.deployment.annotations.BuildStep; -import io.quarkus.deployment.builditem.BytecodeTransformerBuildItem; import io.quarkus.deployment.builditem.CombinedIndexBuildItem; import io.quarkus.deployment.builditem.IndexDependencyBuildItem; import io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem; import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem; import io.quarkus.deployment.builditem.nativeimage.ServiceProviderBuildItem; -import io.quarkus.gizmo.Gizmo; import org.apache.camel.quarkus.support.debezium.DebeziumComponentObserver; import org.apache.kafka.connect.source.SourceTask; import org.jboss.jandex.DotName; import org.jboss.jandex.IndexView; -import org.jboss.logging.Logger; -import org.objectweb.asm.ClassVisitor; -import org.objectweb.asm.MethodVisitor; -import org.objectweb.asm.Opcodes; public class DebeziumSupportProcessor { - private static final Logger LOG = Logger.getLogger(DebeziumSupportProcessor.class); - @BuildStep void addDependencies(BuildProducer indexDependency) { indexDependency.produce(new IndexDependencyBuildItem("org.apache.kafka", "connect-json")); @@ -172,95 +162,4 @@ void registerNativeImageResources(BuildProducer re .produce(new NativeImageResourceBuildItem("META-INF/services/org.apache.kafka.connect.source.SourceConnector")); } - // TODO: Remove this - https://github.com/apache/camel-quarkus/issues/8530 - @BuildStep(onlyIf = KafkaClients42IsPresent.class) - BytecodeTransformerBuildItem patchConfigInfos() { - // Patch ConfigInfos to add values() method as duplicate of configs() - // This provides backward compatibility for Debezium with kafka-clients 4.2.0 - return new BytecodeTransformerBuildItem.Builder() - .setClassToTransform("org.apache.kafka.connect.runtime.rest.entities.ConfigInfos") - .setCacheable(true) - .setVisitorFunction((className, classVisitor) -> new ConfigInfosClassVisitor(classVisitor)) - .build(); - } - - // TODO: Remove this - https://github.com/apache/camel-quarkus/issues/8530 - static final class KafkaClients42IsPresent implements BooleanSupplier { - @Override - public boolean getAsBoolean() { - try { - // Check if ConfigInfos.values() is present. If it's not, then kafka-clients >= 4.2.0 is on the classpath - Class configInfos = Thread.currentThread().getContextClassLoader() - .loadClass("org.apache.kafka.connect.runtime.rest.entities.ConfigInfos"); - configInfos.getDeclaredMethod("values"); - return false; - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } catch (NoSuchMethodException e) { - return true; - } - } - } - - /** - * Adds a values() method to ConfigInfos that duplicates the configs() method. - * This provides backward compatibility with older Debezium versions. - */ - static class ConfigInfosClassVisitor extends ClassVisitor { - - private String configsFieldDescriptor = null; - private String configsMethodSignature = null; - - protected ConfigInfosClassVisitor(ClassVisitor classVisitor) { - super(Gizmo.ASM_API_VERSION, classVisitor); - } - - @Override - public org.objectweb.asm.FieldVisitor visitField(int access, String name, String descriptor, String signature, - Object value) { - // Track the configs field descriptor - if ("configs".equals(name)) { - configsFieldDescriptor = descriptor; - } - return super.visitField(access, name, descriptor, signature, value); - } - - @Override - public MethodVisitor visitMethod(int access, String name, String descriptor, String signature, - String[] exceptions) { - // Track the signature of configs() method - if ("configs".equals(name) && "()Ljava/util/List;".equals(descriptor)) { - configsMethodSignature = signature; - } - return super.visitMethod(access, name, descriptor, signature, exceptions); - } - - @Override - public void visitEnd() { - // Add values() method that duplicates configs() - LOG.debug("Adding values() method to ConfigInfos as duplicate of configs()"); - - MethodVisitor mv = cv.visitMethod( - Opcodes.ACC_PUBLIC, - "values", - "()Ljava/util/List;", - configsMethodSignature, // Same generic signature as configs() - null); - - if (mv != null) { - mv.visitCode(); - // Method body: return this.configs; - mv.visitVarInsn(Opcodes.ALOAD, 0); // Load 'this' - mv.visitFieldInsn(Opcodes.GETFIELD, - "org/apache/kafka/connect/runtime/rest/entities/ConfigInfos", - "configs", - configsFieldDescriptor != null ? configsFieldDescriptor : "Ljava/util/List;"); - mv.visitInsn(Opcodes.ARETURN); // Return the field value - mv.visitMaxs(1, 1); // Max stack=1, max locals=1 - mv.visitEnd(); - } - - super.visitEnd(); - } - } }