FROM quay.io/debezium/server:2.6 COPY ./debezium_conf /debezium/conf EXPOSE 8080
Added to .env
ENABLE_DEBEZIUM_SCRIPTING=true

debezium.sink.type=rabbitmq debezium.sink.rabbitmq.connection.host=${SINK_HOST} debezium.sink.rabbitmq.connection.port=${SINK_PORT} debezium.sink.rabbitmq.connection.username=${SINK_USERNAME} debezium.sink.rabbitmq.connection.password=${SINK_PASSWORD} debezium.sink.rabbitmq.connection.virtual.host=${SINK_VIRTUAL_HOST} debezium.sink.rabbitmq.ackTimeout=3000 debezium.sink.rabbitmq.exchange=${SINK_EXCHANGE} debezium.sink.rabbitmq.routingKey=${SINK_ROUTING_KEY} # Source connector config - PostgreSQL debezium.source.connector.class=io.debezium.connector.postgresql.PostgresConnector debezium.source.plugin.name=pgoutput debezium.source.offset.storage.file.filename=${SOURCE_FILE_OFFSET} debezium.source.offset.flush.interval.ms=0 debezium.source.database.hostname=${SOURCE_HOST} debezium.source.database.port=${SOURCE_PORT} debezium.source.database.user=${SOURCE_USER} debezium.source.database.password=${SOURCE_PASSWORD} debezium.source.database.dbname=${SOURCE_DBNAME} debezium.source.topic.prefix=${SOURCE_TOPIC_PREFIX} # Format config debezium.format.key=json debezium.format.value=json # Quarkus quarkus.log.console.json=false debezium.transforms=route debezium.transforms.route.type=io.debezium.transforms.ContentBasedRouter debezium.transforms.route.language=jsr223.groovy debezium.transforms.route.topic.expression=value.op == 'u' && value.before.is_expired == false && value.after.is_expired == true debezium.transforms.route.topic.regex=${SOURCE_TOPIC_PREFIX} debezium.transforms.route.topic.replacement=consents_expired debezium.transforms.route.null.handling.mode=drop 

2024-05-20 14:11:33,235 INFO [io.deb.tra.ContentBasedRouter] (main) Using language 'jsr223.groovy' to evaluate expression 'value.op == 'u' && value.before.is_expired == false && value.after.is_expired == true'
2024-05-20 14:11:33,240 ERROR [io.deb.ser.ConnectorLifecycle] (main) Connector completed: success = 'false', message = 'Failed to instantiate required class', error = 'java.lang.UnsupportedClassVersionError: com/oracle/truffle/js/scriptengine/GraalJSEngineFactory has been compiled by a more recent version of the Java Runtime (class file version 61.0), this version of the Java Runtime only recognizes class file versions up to 55.0': java.lang.UnsupportedClassVersionError: com/oracle/truffle/js/scriptengine/GraalJSEngineFactory has been compiled by a more recent version of the Java Runtime (class file version 61.0), this version of the Java Runtime only recognizes class file versions up to 55.0