Picked up JAVA_TOOL_OPTIONS: -Dfile.encoding=UTF8
__ ____ __ _____ ___ __ ____ ______
--/ __ \/ / / / _ | / _ \/ //_/ / / / __/
-/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \
--\___\_\____/_/ |_/_/|_/_/|_|\____/___/
2021-10-24 20:05:58,384 INFO [io.deb.ser.BaseChangeConsumer] (main) Using 'io.debezium.server.BaseChangeConsumer$$Lambda$204/0x0000000840255040@48bfb884' stream name mapper
2021-10-24 20:05:58,490 INFO [io.deb.ser.red.RedisStreamChangeConsumer] (main) Using default Jedis 'redis.clients.jedis.Jedis@27b22f74'
2021-10-24 20:05:58,490 INFO [io.deb.ser.DebeziumServer] (main) Consumer 'io.debezium.server.redis.RedisStreamChangeConsumer' instantiated
2021-10-24 20:05:58,787 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values:
converter.type = key
decimal.format = BASE64
schemas.cache.size = 1000
schemas.enable = true
2021-10-24 20:05:58,790 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values:
converter.type = value
decimal.format = BASE64
schemas.cache.size = 1000
schemas.enable = false
2021-10-24 20:05:58,798 INFO [io.deb.emb.EmbeddedEngine$EmbeddedConfig] (main) EmbeddedConfig values:
access.control.allow.methods =
access.control.allow.origin =
admin.listeners = null
bootstrap.servers = [localhost:9092]
client.dns.lookup = use_all_dns_ips
config.providers = []
connector.client.config.override.policy = None
header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
key.converter = class org.apache.kafka.connect.json.JsonConverter
listeners = null
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
offset.flush.interval.ms = 0
offset.flush.timeout.ms = 5000
offset.storage.file.filename = data/offsets.dat
offset.storage.partitions = null
offset.storage.replication.factor = null
offset.storage.topic =
plugin.path = null
response.http.headers.config =
rest.advertised.host.name = null
rest.advertised.listener = null
rest.advertised.port = null
rest.extension.classes = []
rest.host.name = null
rest.port = 8083
ssl.cipher.suites = null
ssl.client.auth = none
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
task.shutdown.graceful.timeout.ms = 5000
topic.creation.enable = true
topic.tracking.allow.reset = true
topic.tracking.enable = true
value.converter = class org.apache.kafka.connect.json.JsonConverter
2021-10-24 20:05:58,799 INFO [org.apa.kaf.con.run.WorkerConfig] (main) Worker configuration property 'internal.key.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration.
2021-10-24 20:05:58,799 INFO [org.apa.kaf.con.run.WorkerConfig] (main) Worker configuration property 'internal.value.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration.
2021-10-24 20:05:58,799 WARN [org.apa.kaf.con.run.WorkerConfig] (main) Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results.
2021-10-24 20:05:58,874 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values:
converter.type = key
decimal.format = BASE64
schemas.cache.size = 1000
schemas.enable = true
2021-10-24 20:05:58,875 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values:
converter.type = value
decimal.format = BASE64
schemas.cache.size = 1000
schemas.enable = true
2021-10-24 20:05:58,876 INFO [io.deb.ser.DebeziumServer] (main) Engine executor started
2021-10-24 20:05:58,891 INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-7-thread-1) Starting FileOffsetBackingStore with file data/offsets.dat
2021-10-24 20:05:59,386 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) Starting OracleConnectorTask with configuration:
2021-10-24 20:05:59,474 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) connector.class = io.debezium.connector.oracle.OracleConnector
2021-10-24 20:05:59,474 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.history.file.filename = data/db_history.dat
2021-10-24 20:05:59,474 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.user = c##dbzuser
2021-10-24 20:05:59,474 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.dbname = CDB$ROOT
2021-10-24 20:05:59,475 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) tasks.max = 1
2021-10-24 20:05:59,475 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.pdb.name = PDB1
2021-10-24 20:05:59,475 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.url = jdbc:oracle:thin:@(DESCRIPTION=(CONNECT_TIMEOUT=5)(TRANSPORT_CONNECT_TIMEOUT=3)(RETRY_COUNT=3)(ADDRESS_LIST=(FAILOVER = on)(LOAD_BALANCE = off)(ADDRESS = (PROTOCOL = TCP)(HOST = 10.20.13.4)(PORT = 1521))(ADDRESS = (PROTOCOL = TCP)(HOST = 10.20.10.3)(PORT = 1521)))(CONNECT_DATA =(SERVER = DEDICATED)(SERVICE_NAME = xxpdb1)))
2021-10-24 20:05:59,475 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.server.name = xxpdb1
2021-10-24 20:05:59,475 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) event.processing.failure.handling.mode = warn
2021-10-24 20:05:59,475 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) internal.log.mining.dml.parser = legacy
2021-10-24 20:05:59,475 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) log.mining.strategy = online_catalog
2021-10-24 20:05:59,476 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) offset.flush.interval.ms = 0
2021-10-24 20:05:59,476 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) tombstones.on.delete = false
2021-10-24 20:05:59,476 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) offset.storage.file.filename = data/offsets.dat
2021-10-24 20:05:59,476 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) column.exclude.list = PROJECT.PUB_SERVICE_AREAS.AREA_GEOM,PROJECT.PUB_PARKING_PLACES.AREA_GEOM
2021-10-24 20:05:59,476 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.password = ********
2021-10-24 20:05:59,476 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) name = redis
2021-10-24 20:05:59,477 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) lob.enabled = true
2021-10-24 20:05:59,477 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) table.include.list = PROJECT.PUB_VEHICLES,PROJECT.PUB_VEHICLE_TYPES,PROJECT.PUB_SERVICE_AREAS,PROJECT.PUB_PARKING_PLACES,PROJECT.PUB_CHARGERS,PROJECT.PUB_PARTNERS,PROJECT.COR_PARAMETER_VALUES,PROJECT.COM_INBOXES,PROJECT.PAY_BALANCES,PROJECT.PUB_PARTNER_BANK_CARDS,PROJECT.SAL_BALANCES,PROJECT.SAL_CONTRACT_PERSONS,PROJECT.SAL_CONTRACTS,PROJECT.SAL_RADAR,PROJECT.SAL_RENTAL_CANCELLATIONS,PROJECT.PUB_PARTNER_DOCUMENTS,PROJECT.SAL_CONTRACT_VEHICLES,PROJECT.COR_LOOKUP_VALUES,PROJECT.PUB_PARTNER_ADDRESSES,PROJECT.PUB_PARTNER_ACCEPTANCES
2021-10-24 20:05:59,477 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.history = io.debezium.relational.history.FileDatabaseHistory
2021-10-24 20:05:59,477 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) snapshot.mode = schema_only
2021-10-24 20:05:59,787 INFO [io.quarkus] (main) debezium-server-dist 1.7.0.Final on JVM (powered by Quarkus 2.0.0.Final) started in 7.503s. Listening on: http://0.0.0.0:8080
2021-10-24 20:05:59,787 INFO [io.quarkus] (main) Profile prod activated.
2021-10-24 20:05:59,787 INFO [io.quarkus] (main) Installed features: [cdi, resteasy, resteasy-jackson, smallrye-context-propagation, smallrye-health]
2021-10-24 20:06:03,184 INFO [io.deb.con.ora.OracleConnection] (pool-7-thread-1) Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production
2021-10-24 20:06:03,574 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) Found previous partition offset io.debezium.connector.oracle.OraclePartition@d394fc03: OracleOffsetContext [scn=20102146660]
2021-10-24 20:06:03,574 INFO [io.deb.rel.his.DatabaseHistoryMetrics] (pool-7-thread-1) Started database history recovery
2021-10-24 20:06:03,875 INFO [io.deb.rel.his.DatabaseHistoryMetrics] (pool-7-thread-1) Finished database history recovery of 20 change(s) in 300 ms
2021-10-24 20:06:04,178 INFO [io.deb.uti.Threads] (pool-7-thread-1) Requested thread factory for connector OracleConnector, id = xxpdb1 named = change-event-source-coordinator
2021-10-24 20:06:04,179 INFO [io.deb.uti.Threads] (pool-7-thread-1) Creating thread debezium-oracleconnector-xxpdb1-change-event-source-coordinator
2021-10-24 20:06:04,188 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Metrics registered
2021-10-24 20:06:04,189 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Context created
2021-10-24 20:06:04,277 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Snapshot ended with SnapshotResult [status=SKIPPED, offset=OracleOffsetContext [scn=20102146660]]
2021-10-24 20:06:04,281 INFO [io.deb.pip.met.StreamingChangeEventSourceMetrics] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Connected metrics set to 'true'
2021-10-24 20:06:04,282 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Starting streaming
2021-10-24 20:06:12,218 ERROR [io.deb.con.ora.log.LogMinerHelper] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Mining session stopped due to the {}: java.lang.ClassCastException: class io.debezium.connector.oracle.logminer.events.LobWriteEvent cannot be cast to class io.debezium.connector.oracle.logminer.events.DmlEvent (io.debezium.connector.oracle.logminer.events.LobWriteEvent and io.debezium.connector.oracle.logminer.events.DmlEvent are in unnamed module of loader 'app')
at io.debezium.connector.oracle.logminer.processor.TransactionReconciliation.reconcile(TransactionReconciliation.java:87)
at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleCommit(MemoryLogMinerEventProcessor.java:235)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:183)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:161)
at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:116)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:162)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:54)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
2021-10-24 20:06:12,219 ERROR [io.deb.pip.ErrorHandler] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Producer failure: java.lang.ClassCastException: class io.debezium.connector.oracle.logminer.events.LobWriteEvent cannot be cast to class io.debezium.connector.oracle.logminer.events.DmlEvent (io.debezium.connector.oracle.logminer.events.LobWriteEvent and io.debezium.connector.oracle.logminer.events.DmlEvent are in unnamed module of loader 'app')
at io.debezium.connector.oracle.logminer.processor.TransactionReconciliation.reconcile(TransactionReconciliation.java:87)
at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleCommit(MemoryLogMinerEventProcessor.java:235)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:183)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:161)
at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:116)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:162)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:54)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
2021-10-24 20:06:12,219 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) startScn=20102146660, endScn=20102166660
2021-10-24 20:06:12,220 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=20110870200, oldestScn=-1, committedScn=null, offsetScn=null, logMinerQueryCount=1, totalProcessedRows=0, totalCapturedDmlCount=0, totalDurationOfFetchingQuery=PT7.123651S, lastCapturedDmlCount=0, lastDurationOfFetchingQuery=PT7.123651S, maxCapturedDmlCount=0, maxDurationOfFetchingQuery=PT7.123651S, totalBatchProcessingDuration=PT0S, lastBatchProcessingDuration=PT0S, maxBatchProcessingDuration=PT0S, maxBatchProcessingThroughput=0, currentLogFileName=null, minLogFilesMined=0, maxLogFilesMined=0, redoLogStatus=null, switchCounter=0, batchSize=21000, millisecondToSleepBetweenMiningQuery=800, hoursToKeepTransaction=0, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT0S, totalStartLogMiningSessionDuration=PT0.013238S, lastStartLogMiningSessionDuration=PT0.013238S, maxStartLogMiningSessionDuration=PT0.013238S, totalProcessTime=PT0S, minBatchProcessTime=PT0S, maxBatchProcessTime=PT0S, totalResultSetNextTime=PT0.000034S, lagFromTheSource=DurationPT7H4M36.215196S, maxLagFromTheSourceDuration=PT7H4M36.215015S, minLagFromTheSourceDuration=PT0S, lastCommitDuration=PT0S, maxCommitDuration=PT0S, activeTransactions=1, rolledBackTransactions=0, committedTransactions=0, abandonedTransactionIds=[], rolledbackTransactionIds=[], registeredDmlCount=0, committedDmlCount=0, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=0, miningSessionUserGlobalAreaMaxMemory=0, miningSessionProcessGlobalAreaMemory=0, miningSessionProcessGlobalAreaMaxMemory=0}
2021-10-24 20:06:12,220 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Offsets: OracleOffsetContext [scn=20102146660]
2021-10-24 20:06:12,220 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Finished streaming
2021-10-24 20:06:12,220 INFO [io.deb.pip.met.StreamingChangeEventSourceMetrics] (debezium-oracleconnector-xxpdb1-change-event-source-coordinator) Connected metrics set to 'false'
2021-10-24 20:06:12,700 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) Stopping down connector
2021-10-24 20:06:12,710 INFO [io.deb.jdb.JdbcConnection] (pool-8-thread-1) Connection gracefully closed
2021-10-24 20:06:12,712 INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-7-thread-1) Stopped FileOffsetBackingStore
2021-10-24 20:06:12,713 INFO [io.deb.ser.ConnectorLifecycle] (pool-7-thread-1) Connector completed: success = 'false', message = 'Error while trying to run connector class 'io.debezium.connector.oracle.OracleConnector'', error = '{}': org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:175)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:54)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.ClassCastException: class io.debezium.connector.oracle.logminer.events.LobWriteEvent cannot be cast to class io.debezium.connector.oracle.logminer.events.DmlEvent (io.debezium.connector.oracle.logminer.events.LobWriteEvent and io.debezium.connector.oracle.logminer.events.DmlEvent are in unnamed module of loader 'app')
at io.debezium.connector.oracle.logminer.processor.TransactionReconciliation.reconcile(TransactionReconciliation.java:87)
at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleCommit(MemoryLogMinerEventProcessor.java:235)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:183)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:161)
at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:116)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:162)
... 8 more
2021-10-24 20:06:12,724 INFO [io.deb.ser.DebeziumServer] (main) Received request to stop the engine
2021-10-24 20:06:12,724 INFO [io.deb.emb.EmbeddedEngine] (main) Stopping the embedded engine
2021-10-24 20:06:12,777 INFO [io.quarkus] (main) debezium-server-dist stopped in 0.063s