[2025-09-29 14:41:11,455] INFO [Worker clientId=connect-10.11.57.201:8083, groupId=connect-cluster-dev] Connector source_cdc_signal_heartbeat config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:2425) [2025-09-29 14:41:11,457] INFO [Worker clientId=connect-10.11.57.201:8083, groupId=connect-cluster-dev] Handling connector-only config update by restarting connector source_cdc_signal_heartbeat (org.apache.kafka.connect.runtime.distributed.DistributedHerder:716) [2025-09-29 14:41:11,457] INFO [source_cdc_signal_heartbeat|worker] Stopping connector source_cdc_signal_heartbeat (org.apache.kafka.connect.runtime.Worker:451) [2025-09-29 14:41:11,457] INFO [source_cdc_signal_heartbeat|worker] Scheduled shutdown for WorkerConnector{id=source_cdc_signal_heartbeat} (org.apache.kafka.connect.runtime.WorkerConnector:294) [2025-09-29 14:41:11,457] INFO 10.11.57.201 - - [29/Sep/2025:09:41:11 +0000] "PUT /connectors/source_cdc_signal_heartbeat/config HTTP/1.1" 200 3354 "-" "ReactorNetty/1.1.10" 56 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2025-09-29 14:41:11,458] INFO [source_cdc_signal_heartbeat|worker] Completed shutdown for WorkerConnector{id=source_cdc_signal_heartbeat} (org.apache.kafka.connect.runtime.WorkerConnector:314) [2025-09-29 14:41:11,458] INFO [Worker clientId=connect-10.11.57.201:8083, groupId=connect-cluster-dev] Starting connector source_cdc_signal_heartbeat (org.apache.kafka.connect.runtime.distributed.DistributedHerder:2077) [2025-09-29 14:41:11,459] INFO [source_cdc_signal_heartbeat|worker] Creating connector source_cdc_signal_heartbeat of type io.debezium.connector.informix.InformixConnector (org.apache.kafka.connect.runtime.Worker:312) [2025-09-29 14:41:11,459] INFO [source_cdc_signal_heartbeat|worker] SourceConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:11,459] INFO [source_cdc_signal_heartbeat|worker] EnrichedConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:11,459] INFO [source_cdc_signal_heartbeat|worker] EnrichedSourceConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:11,460] INFO [source_cdc_signal_heartbeat|worker] EnrichedConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:11,460] INFO [source_cdc_signal_heartbeat|worker] Instantiated connector source_cdc_signal_heartbeat with version 3.2.3.Final of type class io.debezium.connector.informix.InformixConnector (org.apache.kafka.connect.runtime.Worker:334) [2025-09-29 14:41:11,460] INFO [source_cdc_signal_heartbeat|worker] Finished creating connector source_cdc_signal_heartbeat (org.apache.kafka.connect.runtime.Worker:355) name = source_cdc_signal_heartbeat name = source_cdc_signal_heartbeat name = source_cdc_signal_heartbeat name = source_cdc_signal_heartbeat [2025-09-29 14:41:11,466] INFO [Worker clientId=connect-10.11.57.201:8083, groupId=connect-cluster-dev] Tasks [source_cdc_signal_heartbeat-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:2440) [2025-09-29 14:41:11,468] INFO [Worker clientId=connect-10.11.57.201:8083, groupId=connect-cluster-dev] Handling task config update by stopping tasks [source_cdc_signal_heartbeat-0], which will be restarted after rebalance if still assigned to this worker (org.apache.kafka.connect.runtime.distributed.DistributedHerder:784) [2025-09-29 14:41:11,468] INFO [source_cdc_signal_heartbeat|task-0] Stopping task source_cdc_signal_heartbeat-0 (org.apache.kafka.connect.runtime.Worker:1047) [2025-09-29 14:41:11,844] INFO [source_cdc_signal_heartbeat|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask:476) [2025-09-29 14:41:15,844] WARN [source_cdc_signal_heartbeat|task-0] Coordinator didn't stop in the expected time, shutting down executor now (io.debezium.pipeline.ChangeEventSourceCoordinator:379) [2025-09-29 14:41:16,468] ERROR [source_cdc_signal_heartbeat|task-0] Graceful stop of task source_cdc_signal_heartbeat-0 failed. (org.apache.kafka.connect.runtime.Worker:1074) [2025-09-29 14:41:16,469] INFO [source_cdc_signal_heartbeat|task-0] [Producer clientId=connector-producer-source_cdc_signal_heartbeat-0] Closing the Kafka producer with timeoutMillis = 0 ms. (org.apache.kafka.clients.producer.KafkaProducer:1373) [2025-09-29 14:41:16,469] INFO [source_cdc_signal_heartbeat|task-0] [Producer clientId=connector-producer-source_cdc_signal_heartbeat-0] Proceeding to force close the producer since pending requests could not be completed within timeout 0 ms. (org.apache.kafka.clients.producer.KafkaProducer:1407) [2025-09-29 14:41:16,471] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:16,471] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:16,471] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:16,472] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:16,472] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.producer for connector-producer-source_cdc_signal_heartbeat-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:16,474] INFO [Worker clientId=connect-10.11.57.201:8083, groupId=connect-cluster-dev] Joined group at generation 969 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-10.11.57.201:8083-8a17a372-3428-4f55-a55d-d0cbeaeba9a7', leaderUrl='http://10.11.57.201:8083/', offset=2019, connectorIds=[sink_gpdb_dev_trans_request3s, source_cdc_signal_heartbeat, source_19_trans_request1s, sink_sumd_card_funds, source_19_trans_request3s, source_19_sumd_card_funds, source_19_trans_requests, sink_trans_request1s, sink_trans_requests], taskIds=[sink_gpdb_dev_trans_request3s-0, source_cdc_signal_heartbeat-0, source_19_trans_request1s-0, sink_sumd_card_funds-0, source_19_trans_request3s-0, source_19_sumd_card_funds-0, source_19_trans_requests-0, sink_trans_request1s-0, sink_trans_requests-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:2621) [2025-09-29 14:41:16,474] INFO [Worker clientId=connect-10.11.57.201:8083, groupId=connect-cluster-dev] Starting task source_cdc_signal_heartbeat-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:2002) [2025-09-29 14:41:16,475] INFO [source_cdc_signal_heartbeat|task-0] Creating task source_cdc_signal_heartbeat-0 (org.apache.kafka.connect.runtime.Worker:645) [2025-09-29 14:41:16,475] INFO [source_cdc_signal_heartbeat|task-0] ConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:16,475] INFO [source_cdc_signal_heartbeat|task-0] EnrichedConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:16,475] INFO [source_cdc_signal_heartbeat|task-0] TaskConfig values: [2025-09-29 14:41:16,476] INFO [source_cdc_signal_heartbeat|task-0] Instantiated task source_cdc_signal_heartbeat-0 with version 3.2.3.Final of type io.debezium.connector.informix.InformixConnectorTask (org.apache.kafka.connect.runtime.Worker:664) [2025-09-29 14:41:16,476] INFO [source_cdc_signal_heartbeat|task-0] AvroConverterConfig values: [2025-09-29 14:41:16,477] INFO [source_cdc_signal_heartbeat|task-0] KafkaAvroSerializerConfig values: [2025-09-29 14:41:16,477] INFO [source_cdc_signal_heartbeat|task-0] KafkaAvroDeserializerConfig values: [2025-09-29 14:41:16,477] INFO [source_cdc_signal_heartbeat|task-0] AvroDataConfig values: [2025-09-29 14:41:16,477] INFO [source_cdc_signal_heartbeat|task-0] AvroConverterConfig values: [2025-09-29 14:41:16,477] INFO [source_cdc_signal_heartbeat|task-0] KafkaAvroSerializerConfig values: [2025-09-29 14:41:16,477] INFO [source_cdc_signal_heartbeat|task-0] KafkaAvroDeserializerConfig values: [2025-09-29 14:41:16,478] INFO [source_cdc_signal_heartbeat|task-0] AvroDataConfig values: [2025-09-29 14:41:16,478] INFO [source_cdc_signal_heartbeat|task-0] Set up the key converter class io.confluent.connect.avro.AvroConverter for task source_cdc_signal_heartbeat-0 using the connector config (org.apache.kafka.connect.runtime.Worker:679) [2025-09-29 14:41:16,478] INFO [source_cdc_signal_heartbeat|task-0] Set up the value converter class io.confluent.connect.avro.AvroConverter for task source_cdc_signal_heartbeat-0 using the connector config (org.apache.kafka.connect.runtime.Worker:685) [2025-09-29 14:41:16,478] INFO [source_cdc_signal_heartbeat|task-0] Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task source_cdc_signal_heartbeat-0 using the worker config (org.apache.kafka.connect.runtime.Worker:690) [2025-09-29 14:41:16,478] INFO [source_cdc_signal_heartbeat|task-0] Initializing: org.apache.kafka.connect.runtime.TransformationChain{io.debezium.transforms.ExtractNewRecordState} (org.apache.kafka.connect.runtime.Worker:1794) [2025-09-29 14:41:16,478] INFO [source_cdc_signal_heartbeat|task-0] SourceConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:16,478] INFO [source_cdc_signal_heartbeat|task-0] EnrichedConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:16,479] INFO [source_cdc_signal_heartbeat|task-0] EnrichedSourceConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:16,479] INFO [source_cdc_signal_heartbeat|task-0] EnrichedConnectorConfig values: name = source_cdc_signal_heartbeat [2025-09-29 14:41:16,479] INFO [source_cdc_signal_heartbeat|task-0] ProducerConfig values: client.id = connector-producer-source_cdc_signal_heartbeat-0 [2025-09-29 14:41:16,479] INFO [source_cdc_signal_heartbeat|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:269) [2025-09-29 14:41:16,481] INFO [source_cdc_signal_heartbeat|task-0] These configurations '[metrics.context.connect.kafka.cluster.id, metrics.context.connect.group.id]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig:381) [2025-09-29 14:41:16,481] INFO [source_cdc_signal_heartbeat|task-0] Kafka version: 7.8.2-ccs (org.apache.kafka.common.utils.AppInfoParser:124) [2025-09-29 14:41:16,481] INFO [source_cdc_signal_heartbeat|task-0] Kafka commitId: 753ac432ef38a79b7f27781cd77b656d5ffc2e8e (org.apache.kafka.common.utils.AppInfoParser:125) [2025-09-29 14:41:16,481] INFO [source_cdc_signal_heartbeat|task-0] Kafka startTimeMs: 1759138876481 (org.apache.kafka.common.utils.AppInfoParser:126) [2025-09-29 14:41:16,481] INFO [source_cdc_signal_heartbeat|task-0] AdminClientConfig values: client.id = connector-adminclient-source_cdc_signal_heartbeat-0 [2025-09-29 14:41:16,482] INFO [source_cdc_signal_heartbeat|task-0] These configurations '[config.storage.topic, metrics.context.connect.group.id, group.id, status.storage.topic, plugin.path, config.storage.replication.factor, offset.flush.interval.ms, key.converter.schemas.enable, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, value.converter.schemas.enable, log.cleanup.policy, offset.storage.replication.factor, offset.storage.topic, value.converter, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig:381) [2025-09-29 14:41:16,482] INFO [source_cdc_signal_heartbeat|task-0] The mbean of App info: [kafka.admin.client], id: [connector-adminclient-source_cdc_signal_heartbeat-0] already exists, so skipping a new mbean creation. (org.apache.kafka.common.utils.AppInfoParser:65) [2025-09-29 14:41:16,482] INFO [source_cdc_signal_heartbeat|task-0] [Producer clientId=connector-producer-source_cdc_signal_heartbeat-0] Cluster ID: xrvxrofITEuXCboOsCdMfg (org.apache.kafka.clients.Metadata:364) [2025-09-29 14:41:16,483] INFO 10.11.57.201 - - [29/Sep/2025:09:41:11 +0000] "GET /connectors/source_cdc_signal_heartbeat/tasks HTTP/1.1" 200 3366 "-" "ReactorNetty/1.1.10" 5015 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2025-09-29 14:41:16,483] INFO 10.11.57.201 - - [29/Sep/2025:09:41:11 +0000] "GET /connectors/source_cdc_signal_heartbeat HTTP/1.1" 200 3354 "-" "ReactorNetty/1.1.10" 5016 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2025-09-29 14:41:16,484] INFO 10.11.57.201 - - [29/Sep/2025:09:41:11 +0000] "GET /connectors/source_cdc_signal_heartbeat/config HTTP/1.1" 200 3227 "-" "ReactorNetty/1.1.10" 5015 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2025-09-29 14:41:16,484] INFO [source_cdc_signal_heartbeat|task-0] Starting InformixConnectorTask with configuration: name = source_cdc_signal_heartbeat [2025-09-29 14:41:16,484] INFO [source_cdc_signal_heartbeat|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.informix.InformixSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig:1929) [2025-09-29 14:41:16,485] INFO [source_cdc_signal_heartbeat|task-0] Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy (io.debezium.config.CommonConnectorConfig:1617) [2025-09-29 14:41:16,485] INFO 10.11.57.201 - - [29/Sep/2025:09:41:16 +0000] "GET /connectors/source_cdc_signal_heartbeat/tasks/0/status HTTP/1.1" 200 58 "-" "ReactorNetty/1.1.10" 1 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2025-09-29 14:41:16,485] INFO 10.11.57.201 - - [29/Sep/2025:09:41:16 +0000] "GET /connectors/source_cdc_signal_heartbeat/status HTTP/1.1" 200 187 "-" "ReactorNetty/1.1.10" 0 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2025-09-29 14:41:16,485] INFO [source_cdc_signal_heartbeat|task-0] KafkaSchemaHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, enable.auto.commit=false, group.id=inst_kafka_net_41-schemahistory, bootstrap.servers=10.11.57.201:9092, 10.11.57.203:9092, 10.11.57.202:9092, fetch.min.bytes=1, session.timeout.ms=10000, auto.offset.reset=earliest, client.id=inst_kafka_net_41-schemahistory} (io.debezium.storage.kafka.history.KafkaSchemaHistory:249) [2025-09-29 14:41:16,486] INFO [source_cdc_signal_heartbeat|task-0] KafkaSchemaHistory Producer config: {enable.idempotence=false, value.serializer=org.apache.kafka.common.serialization.StringSerializer, batch.size=32768, bootstrap.servers=10.11.57.201:9092, 10.11.57.203:9092, 10.11.57.202:9092, max.in.flight.requests.per.connection=1, buffer.memory=1048576, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=inst_kafka_net_41-schemahistory} (io.debezium.storage.kafka.history.KafkaSchemaHistory:250) [2025-09-29 14:41:16,486] INFO [source_cdc_signal_heartbeat|task-0] Requested thread factory for component InformixConnector, id = inst_kafka_net_41 named = db-history-config-check (io.debezium.util.Threads:273) [2025-09-29 14:41:16,486] WARN [source_cdc_signal_heartbeat|task-0] Unable to register metrics as an old set with the same name: 'debezium.informix_server:type=connector-metrics,context=schema-history,server=inst_kafka_net_41' exists, retrying in PT5S (attempt 1 out of 12) (io.debezium.pipeline.JmxUtils:55) [2025-09-29 14:41:19,845] INFO [source_cdc_signal_heartbeat|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor:122) [2025-09-29 14:41:19,845] INFO [source_cdc_signal_heartbeat|task-0] Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close (io.debezium.util.Threads:273) [2025-09-29 14:41:19,845] INFO [source_cdc_signal_heartbeat|task-0] Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close (io.debezium.util.Threads:290) [2025-09-29 14:41:19,846] INFO [source_cdc_signal_heartbeat|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:988) [2025-09-29 14:41:19,846] INFO [source_cdc_signal_heartbeat|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry:105) [2025-09-29 14:41:19,846] INFO [source_cdc_signal_heartbeat|task-0] Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close (io.debezium.util.Threads:273) [2025-09-29 14:41:19,846] INFO [source_cdc_signal_heartbeat|task-0] Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close (io.debezium.util.Threads:290) [2025-09-29 14:41:19,847] INFO [source_cdc_signal_heartbeat|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:988) [2025-09-29 14:41:19,847] INFO [source_cdc_signal_heartbeat|task-0] Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close (io.debezium.util.Threads:273) [2025-09-29 14:41:19,847] INFO [source_cdc_signal_heartbeat|task-0] Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close (io.debezium.util.Threads:290) [2025-09-29 14:41:21,486] WARN [source_cdc_signal_heartbeat|task-0] Unable to register metrics as an old set with the same name: 'debezium.informix_server:type=connector-metrics,context=schema-history,server=inst_kafka_net_41' exists, retrying in PT5S (attempt 2 out of 12) (io.debezium.pipeline.JmxUtils:55) [2025-09-29 14:41:24,666] ERROR [source_cdc_signal_heartbeat|task-0] Caught Exception (io.debezium.connector.informix.InformixStreamingChangeEventSource:212) [2025-09-29 14:41:24,666] ERROR [source_cdc_signal_heartbeat|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52) [2025-09-29 14:41:24,667] ERROR [source_cdc_signal_heartbeat|task-0] The maximum number of 0 retries has been attempted (io.debezium.pipeline.ErrorHandler:129) [2025-09-29 14:41:24,667] INFO [source_cdc_signal_heartbeat|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:327) [2025-09-29 14:41:24,667] INFO [source_cdc_signal_heartbeat|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:492) [2025-09-29 14:41:24,667] INFO [source_cdc_signal_heartbeat|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:988) [2025-09-29 14:41:24,667] INFO [source_cdc_signal_heartbeat|task-0] [Producer clientId=inst_kafka_net_41-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1373) [2025-09-29 14:41:24,669] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:24,669] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:24,669] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:24,669] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:24,669] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.producer for inst_kafka_net_41-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:24,669] INFO [source_cdc_signal_heartbeat|task-0] [Producer clientId=connector-producer-source_cdc_signal_heartbeat-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1373) [2025-09-29 14:41:24,669] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:24,670] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:24,670] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:24,670] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:24,670] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.producer for connector-producer-source_cdc_signal_heartbeat-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:24,670] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.admin.client for connector-adminclient-source_cdc_signal_heartbeat-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:24,671] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:24,671] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:24,671] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:26,487] INFO [source_cdc_signal_heartbeat|task-0] ProducerConfig values: [2025-09-29 14:41:26,487] INFO [source_cdc_signal_heartbeat|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:269) [2025-09-29 14:41:26,489] INFO [source_cdc_signal_heartbeat|task-0] Kafka version: 7.8.2-ccs (org.apache.kafka.common.utils.AppInfoParser:124) [2025-09-29 14:41:26,489] INFO [source_cdc_signal_heartbeat|task-0] Kafka commitId: 753ac432ef38a79b7f27781cd77b656d5ffc2e8e (org.apache.kafka.common.utils.AppInfoParser:125) [2025-09-29 14:41:26,489] INFO [source_cdc_signal_heartbeat|task-0] Kafka startTimeMs: 1759138886489 (org.apache.kafka.common.utils.AppInfoParser:126) [2025-09-29 14:41:26,489] INFO [source_cdc_signal_heartbeat|task-0] ConsumerConfig values: [2025-09-29 14:41:26,490] INFO [source_cdc_signal_heartbeat|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:269) [2025-09-29 14:41:26,491] INFO [source_cdc_signal_heartbeat|task-0] [Producer clientId=inst_kafka_net_41-schemahistory] Cluster ID: xrvxrofITEuXCboOsCdMfg (org.apache.kafka.clients.Metadata:364) [2025-09-29 14:41:26,491] INFO [source_cdc_signal_heartbeat|task-0] Kafka version: 7.8.2-ccs (org.apache.kafka.common.utils.AppInfoParser:124) [2025-09-29 14:41:26,491] INFO [source_cdc_signal_heartbeat|task-0] Kafka commitId: 753ac432ef38a79b7f27781cd77b656d5ffc2e8e (org.apache.kafka.common.utils.AppInfoParser:125) [2025-09-29 14:41:26,491] INFO [source_cdc_signal_heartbeat|task-0] Kafka startTimeMs: 1759138886491 (org.apache.kafka.common.utils.AppInfoParser:126) [2025-09-29 14:41:26,494] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Cluster ID: xrvxrofITEuXCboOsCdMfg (org.apache.kafka.clients.Metadata:364) [2025-09-29 14:41:26,495] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1055) [2025-09-29 14:41:26,495] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1102) [2025-09-29 14:41:26,495] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:26,495] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,495] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,495] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:26,496] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.consumer for inst_kafka_net_41-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:26,499] INFO [source_cdc_signal_heartbeat|task-0] Found previous partition offset InformixPartition [sourcePartition={databaseName=inst_kafka_net_41}]: {begin_lsn=766114791477272, commit_lsn=766114791477488, change_lsn=766114791477408} (io.debezium.connector.common.BaseSourceTask:576) [2025-09-29 14:41:26,508] INFO [source_cdc_signal_heartbeat|task-0] ConsumerConfig values: [2025-09-29 14:41:26,508] INFO [source_cdc_signal_heartbeat|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:269) [2025-09-29 14:41:26,510] INFO [source_cdc_signal_heartbeat|task-0] Kafka version: 7.8.2-ccs (org.apache.kafka.common.utils.AppInfoParser:124) [2025-09-29 14:41:26,510] INFO [source_cdc_signal_heartbeat|task-0] Kafka commitId: 753ac432ef38a79b7f27781cd77b656d5ffc2e8e (org.apache.kafka.common.utils.AppInfoParser:125) [2025-09-29 14:41:26,510] INFO [source_cdc_signal_heartbeat|task-0] Kafka startTimeMs: 1759138886510 (org.apache.kafka.common.utils.AppInfoParser:126) [2025-09-29 14:41:26,512] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Cluster ID: xrvxrofITEuXCboOsCdMfg (org.apache.kafka.clients.Metadata:364) [2025-09-29 14:41:26,513] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1055) [2025-09-29 14:41:26,513] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1102) [2025-09-29 14:41:26,513] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:26,513] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,513] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,513] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:26,514] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.consumer for inst_kafka_net_41-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:26,514] INFO [source_cdc_signal_heartbeat|task-0] ConsumerConfig values: [2025-09-29 14:41:26,514] INFO [source_cdc_signal_heartbeat|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:269) [2025-09-29 14:41:26,516] INFO [source_cdc_signal_heartbeat|task-0] Kafka version: 7.8.2-ccs (org.apache.kafka.common.utils.AppInfoParser:124) [2025-09-29 14:41:26,516] INFO [source_cdc_signal_heartbeat|task-0] Kafka commitId: 753ac432ef38a79b7f27781cd77b656d5ffc2e8e (org.apache.kafka.common.utils.AppInfoParser:125) [2025-09-29 14:41:26,516] INFO [source_cdc_signal_heartbeat|task-0] Kafka startTimeMs: 1759138886516 (org.apache.kafka.common.utils.AppInfoParser:126) [2025-09-29 14:41:26,516] INFO [source_cdc_signal_heartbeat|task-0] Creating thread debezium-informixconnector-inst_kafka_net_41-db-history-config-check (io.debezium.util.Threads:290) [2025-09-29 14:41:26,516] INFO [source_cdc_signal_heartbeat|task-0] AdminClientConfig values: [2025-09-29 14:41:26,517] INFO [source_cdc_signal_heartbeat|task-0] These configurations '[enable.idempotence, value.serializer, batch.size, max.in.flight.requests.per.connection, buffer.memory, key.serializer]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig:381) [2025-09-29 14:41:26,517] INFO [source_cdc_signal_heartbeat|task-0] Kafka version: 7.8.2-ccs (org.apache.kafka.common.utils.AppInfoParser:124) [2025-09-29 14:41:26,517] INFO [source_cdc_signal_heartbeat|task-0] Kafka commitId: 753ac432ef38a79b7f27781cd77b656d5ffc2e8e (org.apache.kafka.common.utils.AppInfoParser:125) [2025-09-29 14:41:26,517] INFO [source_cdc_signal_heartbeat|task-0] Kafka startTimeMs: 1759138886517 (org.apache.kafka.common.utils.AppInfoParser:126) [2025-09-29 14:41:26,517] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Cluster ID: xrvxrofITEuXCboOsCdMfg (org.apache.kafka.clients.Metadata:364) [2025-09-29 14:41:26,519] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1055) [2025-09-29 14:41:26,519] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1102) [2025-09-29 14:41:26,519] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:26,519] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,519] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,519] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:26,520] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.consumer for inst_kafka_net_41-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:26,522] INFO [source_cdc_signal_heartbeat|task-0] Database schema history topic 'cards_1952_schema-history-trans_requests' has correct settings (io.debezium.storage.kafka.history.KafkaSchemaHistory:492) [2025-09-29 14:41:26,523] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.admin.client for inst_kafka_net_41-schemahistory-topic-check unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:26,523] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:26,523] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,523] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:26,542] INFO [source_cdc_signal_heartbeat|task-0] Requested thread factory for component InformixConnector, id = inst_kafka_net_41 named = SignalProcessor (io.debezium.util.Threads:273) [2025-09-29 14:41:26,543] INFO [source_cdc_signal_heartbeat|task-0] Requested thread factory for component InformixConnector, id = inst_kafka_net_41 named = change-event-source-coordinator (io.debezium.util.Threads:273) [2025-09-29 14:41:26,543] INFO [source_cdc_signal_heartbeat|task-0] Requested thread factory for component InformixConnector, id = inst_kafka_net_41 named = blocking-snapshot (io.debezium.util.Threads:273) [2025-09-29 14:41:26,543] INFO [source_cdc_signal_heartbeat|task-0] Creating thread debezium-informixconnector-inst_kafka_net_41-change-event-source-coordinator (io.debezium.util.Threads:290) [2025-09-29 14:41:26,543] ERROR [source_cdc_signal_heartbeat|task-0] WorkerSourceTask{id=source_cdc_signal_heartbeat-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:233) java.lang.IllegalStateException: DebeziumOpenLineageEmitter not initialized for connector ConnectorContext[connectorLogicalName=inst_kafka_net_41, connectorName=informix, taskId=0, version=3.2.3.Final, config={connector.class=io.debezium.connector.informix.InformixConnector, errors.log.include.messages=true, topic.creation.default.partitions=1, value.converter.schema.registry.subject.name.strategy=io.confluent.kafka.serializers.subject.TopicNameStrategy, key.converter.schema.registry.subject.name.strategy=io.confluent.kafka.serializers.subject.TopicNameStrategy, transforms=unwrap, errors.deadletterqueue.context.headers.enable=true, heartbeat.action.query=UPDATE cdc_signal_heartbeat SET ts = CURRENT where id = 1, transforms.unwrap.drop.tombstones=false, topic.creation.default.replication.factor=3, errors.deadletterqueue.topic.replication.factor=3, transforms.unwrap.type=io.debezium.transforms.ExtractNewRecordState, errors.log.enable=true, key.converter=io.confluent.connect.avro.AvroConverter, topic.creation.default.compression.type=lz4, database.user=kafka, database.dbname=cards_1952, column.skip.list=cards_1952.mcp.ach_accounts.ivr_ach_act_nick,cards_1952.mcp.alert_executed.alert_msg,cards_1952.mcp.alert_executed.alert_template,cards_1952.mcp.alert_executed.alert_data,cards_1952.mcp.alert_executed.description,cards_1952.mcp.campaign_insts.ivr_message,cards_1952.mcp.campaign_insts.push_message,cards_1952.mcp.maa_sent_msg_log.message,cards_1952.mcp.merchants.merchant_image,cards_1952.mcp.stake_holders.stake_holder_logo,cards_1952.mcp.stake_holders.stake_holder_thumbnail,cards_1952.mcp.file_store_binary.file_data,cards_1952.mcp.push_notify_comm_logs.req_payload,cards_1952.mcp.web_activity_log.request_parameters, heartbeat.interval.ms=1800000, schema.history.internal.kafka.bootstrap.servers=10.11.57.201:9092, 10.11.57.203:9092, 10.11.57.202:9092, value.converter.schema.registry.url=http://10.11.57.201:8081, schema.history.internal.kafka.topic.replication.factor=3, errors.max.retries=0, errors.deadletterqueue.topic.name=informix-gpdb-source-errors, database.password=Lahore@556677, name=source_cdc_signal_heartbeat, errors.tolerance=none, skipped.operations=d, pk.mode=kafka, snapshot.mode=schema_only, max.queue.size=100000, tasks.max=1, retriable.restart.connector.wait.ms=60000, database.connection.retry.interval.ms=1000, schema.history.internal.store.only.captured.databases.ddl=true, schema.history.internal.store.only.captured.tables.ddl=true, tombstones.on.delete=true, topic.prefix=inst_kafka_net_41, decimal.handling.mode=double, schema.history.internal.kafka.topic=cards_1952_schema-history-trans_requests, connection.pool.max.size=50, value.converter=io.confluent.connect.avro.AvroConverter, openlineage.integration.enabled=false, topic.creation.default.cleanup.policy=compact, time.precision.mode=connect, database.server.name=inst_kafka_net_41, snapshot.isolation.mode=read_committed, topic.creation.default.retention.ms=604800000, database.port=9260, schema.history.internal.kafka.recovery.poll.interval.ms=30000, offset.flush.interval.ms=10000, task.class=io.debezium.connector.informix.InformixConnectorTask, database.connection.retries=5, database.hostname=10.11.56.182, table.include.list=cards_1952.mcp.cdc_signal_heartbeat, key.converter.schema.registry.url=http://10.11.57.201:8081}]. Call init() first. [2025-09-29 14:41:26,544] INFO [source_cdc_signal_heartbeat|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask:476) [2025-09-29 14:41:26,544] INFO [source_cdc_signal_heartbeat|task-0] Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator:137) [2025-09-29 14:41:26,544] INFO [source_cdc_signal_heartbeat|task-0] Context created (io.debezium.pipeline.ChangeEventSourceCoordinator:140) [2025-09-29 14:41:26,544] INFO [source_cdc_signal_heartbeat|task-0] ConsumerConfig values: [2025-09-29 14:41:26,544] INFO [source_cdc_signal_heartbeat|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:269) [2025-09-29 14:41:26,546] INFO [source_cdc_signal_heartbeat|task-0] Kafka version: 7.8.2-ccs (org.apache.kafka.common.utils.AppInfoParser:124) [2025-09-29 14:41:26,546] INFO [source_cdc_signal_heartbeat|task-0] Kafka commitId: 753ac432ef38a79b7f27781cd77b656d5ffc2e8e (org.apache.kafka.common.utils.AppInfoParser:125) [2025-09-29 14:41:26,546] INFO [source_cdc_signal_heartbeat|task-0] Kafka startTimeMs: 1759138886546 (org.apache.kafka.common.utils.AppInfoParser:126) [2025-09-29 14:41:26,547] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Cluster ID: xrvxrofITEuXCboOsCdMfg (org.apache.kafka.clients.Metadata:364) [2025-09-29 14:41:26,548] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1055) [2025-09-29 14:41:26,548] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1102) [2025-09-29 14:41:26,548] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:26,548] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,548] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,548] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:26,549] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.consumer for inst_kafka_net_41-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:26,549] INFO [source_cdc_signal_heartbeat|task-0] ConsumerConfig values: [2025-09-29 14:41:26,549] INFO [source_cdc_signal_heartbeat|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:269) [2025-09-29 14:41:26,551] INFO [source_cdc_signal_heartbeat|task-0] Kafka version: 7.8.2-ccs (org.apache.kafka.common.utils.AppInfoParser:124) [2025-09-29 14:41:26,551] INFO [source_cdc_signal_heartbeat|task-0] Kafka commitId: 753ac432ef38a79b7f27781cd77b656d5ffc2e8e (org.apache.kafka.common.utils.AppInfoParser:125) [2025-09-29 14:41:26,551] INFO [source_cdc_signal_heartbeat|task-0] Kafka startTimeMs: 1759138886551 (org.apache.kafka.common.utils.AppInfoParser:126) [2025-09-29 14:41:26,553] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Cluster ID: xrvxrofITEuXCboOsCdMfg (org.apache.kafka.clients.Metadata:364) [2025-09-29 14:41:26,555] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1055) [2025-09-29 14:41:26,555] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1102) [2025-09-29 14:41:26,555] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:26,555] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,555] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:26,555] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:26,556] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.consumer for inst_kafka_net_41-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:26,556] INFO [source_cdc_signal_heartbeat|task-0] Started database schema history recovery (io.debezium.relational.history.SchemaHistoryMetrics:115) [2025-09-29 14:41:26,556] INFO [source_cdc_signal_heartbeat|task-0] ConsumerConfig values: [2025-09-29 14:41:26,557] INFO [source_cdc_signal_heartbeat|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:269) [2025-09-29 14:41:26,558] INFO [source_cdc_signal_heartbeat|task-0] Kafka version: 7.8.2-ccs (org.apache.kafka.common.utils.AppInfoParser:124) [2025-09-29 14:41:26,558] INFO [source_cdc_signal_heartbeat|task-0] Kafka commitId: 753ac432ef38a79b7f27781cd77b656d5ffc2e8e (org.apache.kafka.common.utils.AppInfoParser:125) [2025-09-29 14:41:26,558] INFO [source_cdc_signal_heartbeat|task-0] Kafka startTimeMs: 1759138886558 (org.apache.kafka.common.utils.AppInfoParser:126) [2025-09-29 14:41:26,558] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Subscribed to topic(s): cards_1952_schema-history-trans_requests (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:476) [2025-09-29 14:41:26,560] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Cluster ID: xrvxrofITEuXCboOsCdMfg (org.apache.kafka.clients.Metadata:364) [2025-09-29 14:41:26,562] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Discovered group coordinator 10.11.57.203:9092 (id: 2147483644 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:936) [2025-09-29 14:41:26,562] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:604) [2025-09-29 14:41:26,565] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Request joining group due to: need to re-join with the given member-id: inst_kafka_net_41-schemahistory-ecd31636-6cfb-425c-b989-f819972e5fb1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1102) [2025-09-29 14:41:26,565] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:604) [2025-09-29 14:41:26,567] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Successfully joined group with generation Generation{generationId=1, memberId='inst_kafka_net_41-schemahistory-ecd31636-6cfb-425c-b989-f819972e5fb1', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:665) [2025-09-29 14:41:26,567] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Finished assignment for group at generation 1: {inst_kafka_net_41-schemahistory-ecd31636-6cfb-425c-b989-f819972e5fb1=Assignment(partitions=[cards_1952_schema-history-trans_requests-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:663) [2025-09-29 14:41:26,569] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Successfully synced group in generation Generation{generationId=1, memberId='inst_kafka_net_41-schemahistory-ecd31636-6cfb-425c-b989-f819972e5fb1', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:842) [2025-09-29 14:41:26,570] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Notifying assignor about the new Assignment(partitions=[cards_1952_schema-history-trans_requests-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:323) [2025-09-29 14:41:26,570] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Adding newly assigned partitions: cards_1952_schema-history-trans_requests-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:57) [2025-09-29 14:41:26,570] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Found no committed offset for partition cards_1952_schema-history-trans_requests-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1506) [2025-09-29 14:41:26,571] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Resetting offset for partition cards_1952_schema-history-trans_requests-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.11.57.201:9092 (id: 1 rack: null)], epoch=2}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2025-09-29 14:41:26,578] INFO [source_cdc_signal_heartbeat|task-0] Database schema history recovery in progress, recovered 1 records (io.debezium.relational.history.SchemaHistoryMetrics:130) [2025-09-29 14:41:26,578] INFO [source_cdc_signal_heartbeat|task-0] Already applied 1 database changes (io.debezium.relational.history.SchemaHistoryMetrics:140) [2025-09-29 14:41:27,186] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Revoke previously assigned partitions cards_1952_schema-history-trans_requests-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:79) [2025-09-29 14:41:27,186] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Member inst_kafka_net_41-schemahistory-ecd31636-6cfb-425c-b989-f819972e5fb1 sending LeaveGroup request to coordinator 10.11.57.203:9092 (id: 2147483644 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1173) [2025-09-29 14:41:27,186] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1055) [2025-09-29 14:41:27,186] INFO [source_cdc_signal_heartbeat|task-0] [Consumer clientId=inst_kafka_net_41-schemahistory, groupId=inst_kafka_net_41-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1102) [2025-09-29 14:41:27,188] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:27,189] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:27,189] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:27,189] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:27,190] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.consumer for inst_kafka_net_41-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:27,190] INFO [source_cdc_signal_heartbeat|task-0] Finished database schema history recovery of 133 change(s) in 633 ms (io.debezium.relational.history.SchemaHistoryMetrics:121) [2025-09-29 14:41:27,190] INFO [source_cdc_signal_heartbeat|task-0] Parsing default value for column 'ts' with expression 'current' (io.debezium.connector.informix.InformixDefaultValueConverter:50) [2025-09-29 14:41:27,191] ERROR [source_cdc_signal_heartbeat|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52) java.lang.IllegalStateException: DebeziumOpenLineageEmitter not initialized for connector ConnectorContext[connectorLogicalName=inst_kafka_net_41, connectorName=informix, taskId=0, version=3.2.3.Final, config={connector.class=io.debezium.connector.informix.InformixConnector, errors.log.include.messages=true, topic.creation.default.partitions=1, value.converter.schema.registry.subject.name.strategy=io.confluent.kafka.serializers.subject.TopicNameStrategy, key.converter.schema.registry.subject.name.strategy=io.confluent.kafka.serializers.subject.TopicNameStrategy, transforms=unwrap, errors.deadletterqueue.context.headers.enable=true, heartbeat.action.query=UPDATE cdc_signal_heartbeat SET ts = CURRENT where id = 1, transforms.unwrap.drop.tombstones=false, topic.creation.default.replication.factor=3, errors.deadletterqueue.topic.replication.factor=3, transforms.unwrap.type=io.debezium.transforms.ExtractNewRecordState, errors.log.enable=true, key.converter=io.confluent.connect.avro.AvroConverter, topic.creation.default.compression.type=lz4, database.user=kafka, database.dbname=cards_1952, column.skip.list=cards_1952.mcp.ach_accounts.ivr_ach_act_nick,cards_1952.mcp.alert_executed.alert_msg,cards_1952.mcp.alert_executed.alert_template,cards_1952.mcp.alert_executed.alert_data,cards_1952.mcp.alert_executed.description,cards_1952.mcp.campaign_insts.ivr_message,cards_1952.mcp.campaign_insts.push_message,cards_1952.mcp.maa_sent_msg_log.message,cards_1952.mcp.merchants.merchant_image,cards_1952.mcp.stake_holders.stake_holder_logo,cards_1952.mcp.stake_holders.stake_holder_thumbnail,cards_1952.mcp.file_store_binary.file_data,cards_1952.mcp.push_notify_comm_logs.req_payload,cards_1952.mcp.web_activity_log.request_parameters, heartbeat.interval.ms=1800000, schema.history.internal.kafka.bootstrap.servers=10.11.57.201:9092, 10.11.57.203:9092, 10.11.57.202:9092, value.converter.schema.registry.url=http://10.11.57.201:8081, schema.history.internal.kafka.topic.replication.factor=3, errors.max.retries=0, errors.deadletterqueue.topic.name=informix-gpdb-source-errors, database.password=Lahore@556677, name=source_cdc_signal_heartbeat, errors.tolerance=none, skipped.operations=d, pk.mode=kafka, snapshot.mode=schema_only, max.queue.size=100000, tasks.max=1, retriable.restart.connector.wait.ms=60000, database.connection.retry.interval.ms=1000, schema.history.internal.store.only.captured.databases.ddl=true, schema.history.internal.store.only.captured.tables.ddl=true, tombstones.on.delete=true, topic.prefix=inst_kafka_net_41, decimal.handling.mode=double, schema.history.internal.kafka.topic=cards_1952_schema-history-trans_requests, connection.pool.max.size=50, value.converter=io.confluent.connect.avro.AvroConverter, openlineage.integration.enabled=false, topic.creation.default.cleanup.policy=compact, time.precision.mode=connect, database.server.name=inst_kafka_net_41, snapshot.isolation.mode=read_committed, topic.creation.default.retention.ms=604800000, database.port=9260, schema.history.internal.kafka.recovery.poll.interval.ms=30000, offset.flush.interval.ms=10000, task.class=io.debezium.connector.informix.InformixConnectorTask, database.connection.retries=5, database.hostname=10.11.56.182, table.include.list=cards_1952.mcp.cdc_signal_heartbeat, key.converter.schema.registry.url=http://10.11.57.201:8081}]. Call init() first. [2025-09-29 14:41:27,191] INFO [source_cdc_signal_heartbeat|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:492) [2025-09-29 14:41:27,191] INFO [source_cdc_signal_heartbeat|task-0] Creating thread debezium-informixconnector-inst_kafka_net_41-SignalProcessor (io.debezium.util.Threads:290) [2025-09-29 14:41:27,192] INFO [source_cdc_signal_heartbeat|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor:122) [2025-09-29 14:41:27,192] INFO [source_cdc_signal_heartbeat|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry:105) [2025-09-29 14:41:27,192] INFO [source_cdc_signal_heartbeat|task-0] Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close (io.debezium.util.Threads:273) [2025-09-29 14:41:27,192] INFO [source_cdc_signal_heartbeat|task-0] Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close (io.debezium.util.Threads:290) [2025-09-29 14:41:27,193] INFO [source_cdc_signal_heartbeat|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:988) [2025-09-29 14:41:27,193] INFO [source_cdc_signal_heartbeat|task-0] [Producer clientId=inst_kafka_net_41-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1373) [2025-09-29 14:41:27,195] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:27,195] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:27,195] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:27,195] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:27,195] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.producer for inst_kafka_net_41-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:27,195] WARN [source_cdc_signal_heartbeat|task-0] Failed to close source task with type org.apache.kafka.connect.runtime.AbstractWorkerSourceTask$$Lambda$1870/0x00007f9d40e0ec50 (org.apache.kafka.common.utils.Utils:1119) java.lang.IllegalStateException: DebeziumOpenLineageEmitter not initialized for connector ConnectorContext[connectorLogicalName=inst_kafka_net_41, connectorName=informix, taskId=0, version=3.2.3.Final, config={connector.class=io.debezium.connector.informix.InformixConnector, errors.log.include.messages=true, topic.creation.default.partitions=1, value.converter.schema.registry.subject.name.strategy=io.confluent.kafka.serializers.subject.TopicNameStrategy, key.converter.schema.registry.subject.name.strategy=io.confluent.kafka.serializers.subject.TopicNameStrategy, transforms=unwrap, errors.deadletterqueue.context.headers.enable=true, heartbeat.action.query=UPDATE cdc_signal_heartbeat SET ts = CURRENT where id = 1, transforms.unwrap.drop.tombstones=false, topic.creation.default.replication.factor=3, errors.deadletterqueue.topic.replication.factor=3, transforms.unwrap.type=io.debezium.transforms.ExtractNewRecordState, errors.log.enable=true, key.converter=io.confluent.connect.avro.AvroConverter, topic.creation.default.compression.type=lz4, database.user=kafka, database.dbname=cards_1952, column.skip.list=cards_1952.mcp.ach_accounts.ivr_ach_act_nick,cards_1952.mcp.alert_executed.alert_msg,cards_1952.mcp.alert_executed.alert_template,cards_1952.mcp.alert_executed.alert_data,cards_1952.mcp.alert_executed.description,cards_1952.mcp.campaign_insts.ivr_message,cards_1952.mcp.campaign_insts.push_message,cards_1952.mcp.maa_sent_msg_log.message,cards_1952.mcp.merchants.merchant_image,cards_1952.mcp.stake_holders.stake_holder_logo,cards_1952.mcp.stake_holders.stake_holder_thumbnail,cards_1952.mcp.file_store_binary.file_data,cards_1952.mcp.push_notify_comm_logs.req_payload,cards_1952.mcp.web_activity_log.request_parameters, heartbeat.interval.ms=1800000, schema.history.internal.kafka.bootstrap.servers=10.11.57.201:9092, 10.11.57.203:9092, 10.11.57.202:9092, value.converter.schema.registry.url=http://10.11.57.201:8081, schema.history.internal.kafka.topic.replication.factor=3, errors.max.retries=0, errors.deadletterqueue.topic.name=informix-gpdb-source-errors, database.password=Lahore@556677, name=source_cdc_signal_heartbeat, errors.tolerance=none, skipped.operations=d, pk.mode=kafka, snapshot.mode=schema_only, max.queue.size=100000, tasks.max=1, retriable.restart.connector.wait.ms=60000, database.connection.retry.interval.ms=1000, schema.history.internal.store.only.captured.databases.ddl=true, schema.history.internal.store.only.captured.tables.ddl=true, tombstones.on.delete=true, topic.prefix=inst_kafka_net_41, decimal.handling.mode=double, schema.history.internal.kafka.topic=cards_1952_schema-history-trans_requests, connection.pool.max.size=50, value.converter=io.confluent.connect.avro.AvroConverter, openlineage.integration.enabled=false, topic.creation.default.cleanup.policy=compact, time.precision.mode=connect, database.server.name=inst_kafka_net_41, snapshot.isolation.mode=read_committed, topic.creation.default.retention.ms=604800000, database.port=9260, schema.history.internal.kafka.recovery.poll.interval.ms=30000, offset.flush.interval.ms=10000, task.class=io.debezium.connector.informix.InformixConnectorTask, database.connection.retries=5, database.hostname=10.11.56.182, table.include.list=cards_1952.mcp.cdc_signal_heartbeat, key.converter.schema.registry.url=http://10.11.57.201:8081}]. Call init() first. [2025-09-29 14:41:27,195] INFO [source_cdc_signal_heartbeat|task-0] [Producer clientId=connector-producer-source_cdc_signal_heartbeat-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1373) [2025-09-29 14:41:27,197] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:27,197] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:27,197] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:27,197] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694) [2025-09-29 14:41:27,197] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.producer for connector-producer-source_cdc_signal_heartbeat-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:27,197] INFO [source_cdc_signal_heartbeat|task-0] App info kafka.admin.client for connector-adminclient-source_cdc_signal_heartbeat-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:88) [2025-09-29 14:41:27,197] INFO [source_cdc_signal_heartbeat|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684) [2025-09-29 14:41:27,198] INFO [source_cdc_signal_heartbeat|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688) [2025-09-29 14:41:27,198] INFO [source_cdc_signal_heartbeat|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694)