-
Bug
-
Resolution: Done
-
Major
-
None
-
1.7.0.Final
-
None
-
False
-
False
-
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
- is incorporated by
-
DBZ-4159 Store buffered events in separate Infinispan cache
- Closed