2025-04-23 10:36:45,172 INFO   Oracle|relation_cdc_server_1914869802812375042|snapshot [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Snapshot ended with SnapshotResult [status=SKIPPED, offset=OracleOffsetContext [scn=247704826, commit_scn=["247704856:1:07001c00f3050200"], lcr_position=null]] [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-04-23 10:36:45,172 INFO   Oracle|relation_cdc_server_1914869802812375042|snapshot [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] A previous offset indicating a completed snapshot has been found. [io.debezium.relational.RelationalSnapshotChangeEventSource]
2025-04-23 10:36:45,172 INFO   Oracle|relation_cdc_server_1914869802812375042|snapshot [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Context created [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-04-23 10:36:45,172 INFO   Oracle|relation_cdc_server_1914869802812375042|snapshot [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-04-23 10:36:44,574 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] App info kafka.producer for connector-producer-relation_cdc_server_1914869802812375042_1914857663359942658-0 unregistered [org.apache.kafka.common.utils.AppInfoParser]
2025-04-23 10:36:44,574 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Metrics reporters closed [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:44,573 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:44,573 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:44,573 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:44,573 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Producer clientId=connector-producer-relation_cdc_server_1914869802812375042_1914857663359942658-0] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer]
2025-04-23 10:36:44,573 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] App info kafka.producer for relation_cdc_server_1914869802812375042-schemahistory unregistered [org.apache.kafka.common.utils.AppInfoParser]
2025-04-23 10:36:44,573 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Metrics reporters closed [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:44,573 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:44,573 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:44,573 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:44,572 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Producer clientId=relation_cdc_server_1914869802812375042-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer]
2025-04-23 10:36:44,572 INFO   || [pool-12-thread-1hread] Connection gracefully closed [io.debezium.jdbc.JdbcConnection]
2025-04-23 10:36:44,569 INFO   || [pool-11-thread-1hread] Connection gracefully closed [io.debezium.jdbc.JdbcConnection]
2025-04-23 10:36:44,562 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Debezium ServiceRegistry stopped. [io.debezium.service.DefaultServiceRegistry]
2025-04-23 10:36:44,562 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] SignalProcessor stopped [io.debezium.pipeline.signal.SignalProcessor]
2025-04-23 10:36:44,562 INFO   Oracle|relation_cdc_server_1914869802812375042|streaming [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Connected metrics set to 'false' [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-04-23 10:36:44,562 INFO   Oracle|relation_cdc_server_1914869802812375042|streaming [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Finished streaming [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-04-23 10:36:44,562 INFO   Oracle|relation_cdc_server_1914869802812375042|streaming [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Offsets: OracleOffsetContext [scn=247704856, commit_scn=["247704856:1:07001c00f3050200"], lcr_position=null] [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource]
2025-04-23 10:36:44,562 INFO   Oracle|relation_cdc_server_1914869802812375042|streaming [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Streaming metrics dump: LogMinerStreamingChangeEventSourceMetrics{connectorConfig=io.debezium.connector.oracle.OracleConnectorConfig@64f3ad95, startTime=2025-04-23T02:31:53.674335121Z, clock=SystemClock[Z], currentScn=247704869, offsetScn=247704856, commitScn=247704854, oldestScn=null, oldestScnTime=null, currentLogFileNames=[/data/u01/app/oracle/oradata/orcl/redo10.log], redoLogStatuses=[/data/u01/app/oracle/oradata/orcl/redo10.log | CURRENT, /data/u01/app/oracle/oradata/orcl/redo06.log | INACTIVE, /data/u01/app/oracle/oradata/orcl/redo07.log | INACTIVE, /data/u01/app/oracle/oradata/orcl/redo05.log | INACTIVE, /data/u01/app/oracle/oradata/orcl/redo09.log | INACTIVE, /data/u01/app/oracle/oradata/orcl/redo08.log | INACTIVE], databaseZoneOffset=+08:00, batchSize=20000, logSwitchCount=0, logMinerQueryCount=60, sleepTime=3000, minimumLogsMined=1, maximumLogsMined=1, maxBatchProcessingThroughput=19, timeDifference=-10390, processedRowsCount=2253, activeTransactionCount=1, rolledBackTransactionCount=0, oversizedTransactionCount=0, changesCount=2000, scnFreezeCount=0, batchProcessingDuration={min=PT0.041728322S,max=PT1M45.426102778S,total=PT1M48.01393986S}, fetchQueryDuration={min=PT0.035962148S,max=PT0.075797977S,total=PT2.234652541S}, commitDuration={min=PT0.00000215S,max=PT0S,total=PT0.001959746S}, lagFromSourceDuration={min=PT0.876530989S,max=PT6.552129102S,total=PT2H14M55.124570801S}, miningSessionStartupDuration={min=PT0.00230352S,max=PT0.004988337S,total=PT0.099202623S}, parseTimeDuration={min=PT0.000008015S,max=PT0S,total=PT0.017357102S}, resultSetNextDuration={min=PT0.000000111S,max=PT0S,total=PT0.000344224S}, userGlobalAreaMemory={value=10515664,max=30789648}, processGlobalAreaMemory={value=16523608,max=36512088}, abandonedTransactionIds=[], rolledBackTransactionIds=[]}  [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource]
2025-04-23 10:36:44,561 INFO   Oracle|relation_cdc_server_1914869802812375042|streaming [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] startScn=247704856, endScn=247704866 [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource]
	at java.base/java.lang.Thread.run(Thread.java:1583)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:324)
	at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:62)
	at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:243)
	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:322)
	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:476)
	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:547)
	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleCommit(AbstractLogMinerEventProcessor.java:769)
	at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.accept(TransactionCommitConsumer.java:121)
	at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.dispatchChangeEvent(TransactionCommitConsumer.java:499)
	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.lambda$handleCommit$13(AbstractLogMinerEventProcessor.java:753)
	at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:281)
	at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:47)
	at io.debezium.relational.RelationalChangeRecordEmitter.emitCreateRecord(RelationalChangeRecordEmitter.java:79)
	at io.debezium.pipeline.EventDispatcher$2.changeRecord(EventDispatcher.java:311)
	at io.debezium.pipeline.EventDispatcher$StreamingChangeRecordReceiver.changeRecord(EventDispatcher.java:532)
	at io.debezium.connector.base.ChangeEventQueue.enqueue(ChangeEventQueue.java:181)
	at io.debezium.connector.base.ChangeEventQueue.doEnqueue(ChangeEventQueue.java:225)
	at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1859)
java.lang.InterruptedException
2025-04-23 10:36:41,553 WARN   Oracle|relation_cdc_server_1914869802812375042|streaming [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Error while processing event at offset {commit_scn=247704856:1:07001c00f3050200, snapshot_scn=247703585, scn=247704844} [io.debezium.pipeline.EventDispatcher]
2025-04-23 10:36:41,552 WARN   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Coordinator didn't stop in the expected time, shutting down executor now [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-04-23 10:36:40,171 WARN   Oracle|relation_cdc_server_1914869802812375042|snapshot [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Unable to register metrics as an old set with the same name exists, retrying in PT5S (attempt 5 out of 12) [io.debezium.pipeline.JmxUtils]
2025-04-23 10:36:38,155 INFO   || [SourceTaskOffsetCommitter-1hread] WorkerSourceTask{id=relation_cdc_server_1914619616299122689_1914564421700935682-0} Committing offsets for 1 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-04-23 10:36:35,171 WARN   Oracle|relation_cdc_server_1914869802812375042|snapshot [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Unable to register metrics as an old set with the same name exists, retrying in PT5S (attempt 4 out of 12) [io.debezium.pipeline.JmxUtils]
[2470.407s][info   ][gc,cpu      ] GC(46) User=0.04s Sys=0.01s Real=0.02s
[2470.407s][info   ][gc          ] GC(46) Pause Young (Normal) (G1 Evacuation Pause) 691M->95M(1024M) 18.915ms
[2470.407s][info   ][gc,metaspace] GC(46) Metaspace: 113490K(114496K)->113490K(114496K) NonClass: 98081K(98624K)->98081K(98624K) Class: 15408K(15872K)->15408K(15872K)
[2470.407s][info   ][gc,heap     ] GC(46) Humongous regions: 4->4
[2470.407s][info   ][gc,heap     ] GC(46) Old regions: 74->74
[2470.407s][info   ][gc,heap     ] GC(46) Survivor regions: 6->18(77)
[2470.407s][info   ][gc,heap     ] GC(46) Eden regions: 608->0(218)
[2470.407s][info   ][gc,phases   ] GC(46)   Other: 0.1ms
[2470.407s][info   ][gc,phases   ] GC(46)   Post Evacuate Collection Set: 1.1ms
[2470.407s][info   ][gc,phases   ] GC(46)   Evacuate Collection Set: 17.1ms
[2470.407s][info   ][gc,phases   ] GC(46)   Merge Heap Roots: 0.2ms
[2470.407s][info   ][gc,phases   ] GC(46)   Pre Evacuate Collection Set: 0.3ms
[2470.388s][info   ][gc,task     ] GC(46) Using 2 workers of 2 for evacuation
[2470.388s][info   ][gc,start    ] GC(46) Pause Young (Normal) (G1 Evacuation Pause)
2025-04-23 10:36:30,171 WARN   Oracle|relation_cdc_server_1914869802812375042|snapshot [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Unable to register metrics as an old set with the same name exists, retrying in PT5S (attempt 3 out of 12) [io.debezium.pipeline.JmxUtils]
2025-04-23 10:36:25,170 WARN   Oracle|relation_cdc_server_1914869802812375042|snapshot [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Unable to register metrics as an old set with the same name exists, retrying in PT5S (attempt 2 out of 12) [io.debezium.pipeline.JmxUtils]
2025-04-23 10:36:20,170 WARN   Oracle|relation_cdc_server_1914869802812375042|snapshot [debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinatorhread] Unable to register metrics as an old set with the same name exists, retrying in PT5S (attempt 1 out of 12) [io.debezium.pipeline.JmxUtils]
2025-04-23 10:36:20,169 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] WorkerSourceTask{id=relation_cdc_server_1914869802812375042_1914857663359942658-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask]
2025-04-23 10:36:20,169 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Creating thread debezium-oracleconnector-relation_cdc_server_1914869802812375042-change-event-source-coordinator [io.debezium.util.Threads]
2025-04-23 10:36:20,169 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Requested thread factory for component OracleConnector, id = relation_cdc_server_1914869802812375042 named = blocking-snapshot [io.debezium.util.Threads]
2025-04-23 10:36:20,169 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Requested thread factory for component OracleConnector, id = relation_cdc_server_1914869802812375042 named = change-event-source-coordinator [io.debezium.util.Threads]
2025-04-23 10:36:20,169 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Requested thread factory for component OracleConnector, id = relation_cdc_server_1914869802812375042 named = SignalProcessor [io.debezium.util.Threads]
2025-04-23 10:36:20,168 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Found previous offset OracleOffsetContext [scn=247704826, commit_scn=["247704856:1:07001c00f3050200"], lcr_position=null] [io.debezium.connector.oracle.OracleConnectorTask]
2025-04-23 10:36:20,168 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Finished database schema history recovery of 47 change(s) in 3597 ms [io.debezium.relational.history.SchemaHistoryMetrics]
2025-04-23 10:36:20,168 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] App info kafka.consumer for relation_cdc_server_1914869802812375042-schemahistory unregistered [org.apache.kafka.common.utils.AppInfoParser]
2025-04-23 10:36:20,166 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Metrics reporters closed [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:20,166 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:20,166 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:20,166 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics]
2025-04-23 10:36:19,681 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Request joining group due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:19,681 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:19,681 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Member relation_cdc_server_1914869802812375042-schemahistory-3a6baa94-64db-4900-8bb3-62c46685e108 sending LeaveGroup request to coordinator 10.106.253.24:9092 (id: 2147483646 rack: null) due to the consumer is being closed [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:19,681 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Revoke previously assigned partitions relation_cdc_server_1914869802812375042_history.DACOO-0 [org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker]
2025-04-23 10:36:19,665 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Already applied 1 database changes [io.debezium.relational.history.SchemaHistoryMetrics]
2025-04-23 10:36:19,664 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] Database schema history recovery in progress, recovered 1 records [io.debezium.relational.history.SchemaHistoryMetrics]
2025-04-23 10:36:19,624 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Resetting offset for partition relation_cdc_server_1914869802812375042_history.DACOO-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.106.253.24:9092 (id: 1 rack: null)], epoch=absent}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState]
2025-04-23 10:36:19,583 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Found no committed offset for partition relation_cdc_server_1914869802812375042_history.DACOO-0 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:19,582 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Adding newly assigned partitions: relation_cdc_server_1914869802812375042_history.DACOO-0 [org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker]
2025-04-23 10:36:19,582 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Notifying assignor about the new Assignment(partitions=[relation_cdc_server_1914869802812375042_history.DACOO-0]) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:19,582 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Successfully synced group in generation Generation{generationId=1, memberId='relation_cdc_server_1914869802812375042-schemahistory-3a6baa94-64db-4900-8bb3-62c46685e108', protocol='range'} [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:19,580 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Finished assignment for group at generation 1: {relation_cdc_server_1914869802812375042-schemahistory-3a6baa94-64db-4900-8bb3-62c46685e108=Assignment(partitions=[relation_cdc_server_1914869802812375042_history.DACOO-0])} [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:19,580 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Successfully joined group with generation Generation{generationId=1, memberId='relation_cdc_server_1914869802812375042-schemahistory-3a6baa94-64db-4900-8bb3-62c46685e108', protocol='range'} [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:16,579 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] (Re-)joining group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:16,579 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] Request joining group due to: need to re-join with the given member-id: relation_cdc_server_1914869802812375042-schemahistory-3a6baa94-64db-4900-8bb3-62c46685e108 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
2025-04-23 10:36:16,577 INFO   || [task-thread-relation_cdc_server_1914869802812375042_1914857663359942658-0hread] [Consumer clientId=relation_cdc_server_1914869802812375042-schemahistory, groupId=relation_cdc_server_1914869802812375042-schemahistory] (Re-)joining group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]