In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.

Bug report

For bug reports, provide this information, please:

What Debezium connector do you use and what version?

2.5.0

Aiven SaaS service Apache Kafka Connect 3.8.1
MySQL connector:
Debezium - MySQL
Version: 2.5.0 |
Author: Debezium

What is the connector configuration?

 

{     "topic.prefix": "widget_prim",     "event.processing.failure.handling.mode": "ignore",     "name": "widget_prim",     "database.hostname": "xxx.xxx.xxx.xxxx",     "schema.history.internal.skip.unparseable.ddl": "true",     "connector.class": "io.debezium.connector.mysql.MySqlConnector",     "database.port": "33059",     "schema.history.internal.store.only.captured.tables.ddl": "true",     "tasks.max": "1",     "database.user": "xxx",     "errors.log.enable": "true",     "database.password": "xxx",     "errors.log.include.messages": "true",     "database.server.id": "1011",     "snapshot.include.collection.list": "xxx.carrier_point,xxx.branch,xxx.branch_displaying_state,xxx.branch_group_branch,xxx.branch_export_attributes,xxx.branch_attribute,xxx.branch_photo,xxx.branch_group,xxx.country,xxx.carrier_dimensions,xxx.dimensions,xxx.carrier_yyyyyyery_region,xxx.carrier_yyyyyyery_place,xxx.zzzz_detail",     "table.include.list": "xxx.carrier_point,xxx.branch,xxx.branch_displaying_state,xxx.branch_group_branch,xxx.branch_export_attributes,xxx.branch_attribute,xxx.branch_photo,xxx.branch_group,xxx.country,xxx.carrier_dimensions,xxx.dimensions,xxx.carrier_yyyyyyery_region,xxx.carrier_yyyyyyery_place,xxx.zzzz_detail",     "decimal.handling.mode": "string",     "snapshot.lock.timeout.ms": "120000",     "message.key.columns": "xxx.branch_attribute:branch_id;xxx.branch_displaying_state:branch_id;xxx.branch_export_attributes:branch_id;xxx.branch_group_branch:branch_id;xxx.branch_photo:branch_id;xxx.carrier_dimensions:class,dimensions_id;xxx.dimensions:id;xxx.carrier_yyyyyyery_place:branch_id;xxx.zzzz_detail:branch_id",     "connect.keep.alive": "true",     "snapshot.mode": "schema_only",     "snapshot.locking.mode": "none",     "time.precision.mode": "connect",     "table.ignore.builtin": "true",     "event.deserialization.failure.handling.mode": "ignore",     "auto.create.topics.enable": "false",     "database.dbname": "xxx.,     "database.server.name": "widget_prim",     "schema.history.internal.consumer.security.protocol": "SSL",     "schema.history.internal.consumer.ssl.key.password": "password",     "schema.history.internal.consumer.ssl.keystore.location": "/run/aiven/keys/public.keystore.p12",     "schema.history.internal.consumer.ssl.keystore.password": "password",     "schema.history.internal.consumer.ssl.keystore.type": "PKCS12",     "schema.history.internal.consumer.ssl.truststore.location": "/run/aiven/keys/public.truststore.jks",     "schema.history.internal.consumer.ssl.truststore.password": "password",     "schema.history.internal.kafka.bootstrap.servers": "xxxx",     "schema.history.internal.kafka.recovery.poll.interval.ms": "5000",     "schema.history.internal.kafka.topic": "widget_prim.dbhistory",     "schema.history.internal.producer.security.protocol": "SSL",     "schema.history.internal.producer.ssl.key.password": "password",     "schema.history.internal.producer.ssl.keystore.location": "/run/aiven/keys/public.keystore.p12",     "schema.history.internal.producer.ssl.keystore.password": "password",     "schema.history.internal.producer.ssl.keystore.type": "PKCS12",     "schema.history.internal.producer.ssl.truststore.location": "/run/aiven/keys/public.truststore.jks",     "schema.history.internal.producer.ssl.truststore.password": "password",     "schema.history.internal.store.only.monitored.tables.ddl": "true",     "topic.creation.default.partitions": "10",     "topic.creation.default.replication.factor": "3",     "topic.creation.default.retention.bytes": "-1",     "topic.creation.default.retention.ms": "345600000",     "topic.creation.enable": "false", }

What is the captured database version and mode of deployment?

(E.g. on-premises, with a specific cloud provider, etc.)

Azure VM
MariaDB [(none)]> SELECT VERSION();
-----------------------------

-----------------------------

-----------------------------

What behavior do you expect?

Running connector

What behavior do you see?

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:67)
    at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:298)
    at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$30(MySqlStreamingChangeEventSource.java:876)
    at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1263)
    at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1089)
    at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648)
    at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949)
    at java.base/java.lang.Thread.run(Thread.java:840)
Caused by: io.debezium.DebeziumException: Error processing binlog event
    ... 7 more
Caused by: java.lang.NullPointerException

and:

[2025-01-21 06:29:00,945] ERROR [widget_prim|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52)
io.debezium.DebeziumException: Error processing binlog event
at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:298)
at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$30(MySqlStreamingChangeEventSource.java:876)
at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1263)
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1089)
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648)
at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949)
at java.base/java.lang.Thread.run(Thread.java:840)
Caused by: java.lang.NullPointerException: Cannot invoke "java.util.List.iterator()" because the return value of "java.util.Map.get(Object)" is null
at io.debezium.antlr.DataTypeResolver.resolveDataType(DataTypeResolver.java:54)
at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:147)
at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.enterColumnDefinition(ColumnDefinitionParserListener.java:75)
at io.debezium.ddl.parser.mysql.generated.MySqlParser$ColumnDefinitionContext.enterRule(MySqlParser.java:8955)
at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46)
at io.debezium.connector.mysql.antlr.listener.MySqlAntlrDdlParserListener.enterEveryRule(MySqlAntlrDdlParserListener.java:89)
at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:49)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:33)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:83)
at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:213)
at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:199)
at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:508)
at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$18(MySqlStreamingChangeEventSource.java:846)
at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:278)
... 6 more

after:

SHOW BINLOG EVENTS IN 'mysql-bin.232001' FROM 18468800;

Log_name        Pos     Event_type      Server_id       End_log_pos     Info
mysql-bin.232001        18468800        Query   1011001 18469871        use `xxx`; CREATE TABLE `carrier_pickup_orders` (\n  `id` int(10) UNSIGNED NOT NULL AUTO_INCREMENT,\n  `pickup_id` uuid NOT NULL,\n  `user_id` int(11) NOT NULL,\n  `eshop_id` int(11) NOT NULL,\n  `carrier_class` varchar(255) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NOT NULL,\n  `carrier_id` varchar(255) NULL,\n  `created` timestamp NOT NULL DEFAULT current_timestamp(),\n  `cancelled` timestamp NULL DEFAULT NULL,\n  PRIMARY KEY (`id`),\n  UNIQUE KEY `pickup_id` (`pickup_id`),\n  KEY `user_id` (`user_id`),\n  KEY `eshop_id` (`eshop_id`),\n  KEY `carrier_class` (`carrier_class`),\n  CONSTRAINT `carrier_pickup_orders_ibfk_1` FOREIGN KEY (`user_id`) REFERENCES `uzivatel` (`ID_UZ`) ON DELETE CASCADE ON UPDATE CASCADE,\n  CONSTRAINT `carrier_pickup_orders_ibfk_2` FOREIGN KEY (`eshop_id`) REFERENCES `eshop` (`id`) ON DELETE CASCADE ON UPDATE CASCADE,\n  CONSTRAINT `carrier_pickup_orders_ibfk_3` FOREIGN KEY (`carrier_class`) REFERENCES `carrier_class` (`name`) ON DELETE CASCADE ON UPDATE CASCADE\n)
mysql-bin.232001        18469871        Gtid    1011001 18469913        BEGIN GTID 0-1011001-86215163849

Do you see the same behaviour using the latest released Debezium version?

(Ideally, also verify with latest Alpha/Beta/CR version)

Running in Aiven SaaS, this is the latst version available.

Do you have the connector logs, ideally from start till finish?

(You might be asked later to provide DEBUG/TRACE level log)

yes, but cannot send publicly due sensitive values, interesting part:
prim_kafka_connect-2025-01-21,akCOh5QBTi1R4RdCK2Oo,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:28,366] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Subscribed to topic(s): widget_prim.dbhistory (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:476)",1737441028.367266,"Jan 21, 2025 @ 07:30:28.367"
prim_kafka_connect-2025-01-21,cECOh5QBTi1R4RdCK2Oo,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:28,447] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Cluster ID: q7YoXmNlTxqiTiHesdlFXg (org.apache.kafka.clients.Metadata:364)",1737441028.449309,"Jan 21, 2025 @ 07:30:28.449"
prim_kafka_connect-2025-01-21,cUCOh5QBTi1R4RdCK2Oo,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:28,512] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Discovered group coordinator 172.205.210.42:27426 (id: 2147483609 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:936)",1737441028.514072,"Jan 21, 2025 @ 07:30:28.514"
prim_kafka_connect-2025-01-21,c0COh5QBTi1R4RdCK2Oo,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:28,516] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:604)",1737441028.516451,"Jan 21, 2025 @ 07:30:28.516"
prim_kafka_connect-2025-01-21,dUCOh5QBTi1R4RdCK2Oo,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:28,620] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Request joining group due to: need to re-join with the given member-id: widget_prim-schemahistory-45e5bb82-51b9-4286-8964-c6283abacbf0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1102)",1737441028.624704,"Jan 21, 2025 @ 07:30:28.624"
prim_kafka_connect-2025-01-21,dkCOh5QBTi1R4RdCK2Oo,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:28,621] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:604)",1737441028.624823,"Jan 21, 2025 @ 07:30:28.624"
prim_kafka_connect-2025-01-21,jkCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:31,624] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Successfully joined group with generation Generation{generationId=1, memberId='widget_prim-schemahistory-45e5bb82-51b9-4286-8964-c6283abacbf0', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:665)",1737441031.624415,"Jan 21, 2025 @ 07:30:31.624"
prim_kafka_connect-2025-01-21,kECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:31,664] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Finished assignment for group at generation 1: {widget_prim-schemahistory-45e5bb82-51b9-4286-8964-c6283abacbf0=Assignment(partitions=[widget_prim.dbhistory-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:663)",1737441031.665435,"Jan 21, 2025 @ 07:30:31.665"
prim_kafka_connect-2025-01-21,kkCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:31,680] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Successfully synced group in generation Generation{generationId=1, memberId='widget_prim-schemahistory-45e5bb82-51b9-4286-8964-c6283abacbf0', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:842)",1737441031.68103,"Jan 21, 2025 @ 07:30:31.681"
prim_kafka_connect-2025-01-21,k0COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:31,681] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Notifying assignor about the new Assignment(partitions=[widget_prim.dbhistory-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:323)",1737441031.68155,"Jan 21, 2025 @ 07:30:31.681"
prim_kafka_connect-2025-01-21,lECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:31,682] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Adding newly assigned partitions: widget_prim.dbhistory-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:57)",1737441031.682419,"Jan 21, 2025 @ 07:30:31.682"
prim_kafka_connect-2025-01-21,mECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:31,692] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Found no committed offset for partition widget_prim.dbhistory-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1506)",1737441031.692702,"Jan 21, 2025 @ 07:30:31.692"
prim_kafka_connect-2025-01-21,mkCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:31,695] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Resetting offset for partition widget_prim.dbhistory-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.205.210.42:27426 (id: 38 rack: westeurope/3)], epoch=494}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)",1737441031.695188,"Jan 21, 2025 @ 07:30:31.695"
prim_kafka_connect-2025-01-21,nECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:31,734] INFO [widget_prim|task-0] Database schema history recovery in progress, recovered 1 records (io.debezium.relational.history.SchemaHistoryMetrics:130)",1737441031.735638,"Jan 21, 2025 @ 07:30:31.735"
prim_kafka_connect-2025-01-21,n0COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:31,744] INFO [widget_prim|task-0] Already applied 1 database changes (io.debezium.relational.history.SchemaHistoryMetrics:140)",1737441031.74595,"Jan 21, 2025 @ 07:30:31.745"
prim_kafka_connect-2025-01-21,pECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,300] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Revoke previously assigned partitions widget_prim.dbhistory-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:79)",1737441032.301233,"Jan 21, 2025 @ 07:30:32.301"
prim_kafka_connect-2025-01-21,pUCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,301] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Member widget_prim-schemahistory-45e5bb82-51b9-4286-8964-c6283abacbf0 sending LeaveGroup request to coordinator 172.205.210.42:27426 (id: 2147483609 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1173)",1737441032.301597,"Jan 21, 2025 @ 07:30:32.301"
prim_kafka_connect-2025-01-21,pkCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,302] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1055)",1737441032.303019,"Jan 21, 2025 @ 07:30:32.303"
prim_kafka_connect-2025-01-21,p0COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,303] INFO [widget_prim|task-0] [Consumer clientId=widget_prim-schemahistory, groupId=widget_prim-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1102)",1737441032.303226,"Jan 21, 2025 @ 07:30:32.303"
prim_kafka_connect-2025-01-21,x0COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,786] INFO [widget_prim|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684)",1737441032.786862,"Jan 21, 2025 @ 07:30:32.786"
prim_kafka_connect-2025-01-21,yECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,787] INFO [widget_prim|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688)",1737441032.789657,"Jan 21, 2025 @ 07:30:32.789"
prim_kafka_connect-2025-01-21,yUCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,787] INFO [widget_prim|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688)",1737441032.789739,"Jan 21, 2025 @ 07:30:32.789"
prim_kafka_connect-2025-01-21,ykCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,787] INFO [widget_prim|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694)",1737441032.789792,"Jan 21, 2025 @ 07:30:32.789"
prim_kafka_connect-2025-01-21,y0COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,795] INFO [widget_prim|task-0] App info kafka.consumer for widget_prim-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88)",1737441032.79663,"Jan 21, 2025 @ 07:30:32.796"
prim_kafka_connect-2025-01-21,zECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,795] INFO [widget_prim|task-0] Finished database schema history recovery of 274 change(s) in 4534 ms (io.debezium.relational.history.SchemaHistoryMetrics:121)",1737441032.796724,"Jan 21, 2025 @ 07:30:32.796"
prim_kafka_connect-2025-01-21,zUCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,843] INFO [widget_prim|task-0] Reconnecting after finishing schema recovery (io.debezium.connector.mysql.MySqlConnectorTask:120)",1737441032.84464,"Jan 21, 2025 @ 07:30:32.844"
prim_kafka_connect-2025-01-21,0UCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,863] INFO [widget_prim|task-0] Get all known binlogs (io.debezium.connector.mysql.strategy.AbstractConnectorConnection:149)",1737441032.863381,"Jan 21, 2025 @ 07:30:32.863"
prim_kafka_connect-2025-01-21,00COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,877] INFO [widget_prim|task-0] Server has the binlog file 'mysql-bin.231988' required by the connector (io.debezium.connector.mysql.strategy.AbstractConnectorConnection:391)",1737441032.877324,"Jan 21, 2025 @ 07:30:32.877"
prim_kafka_connect-2025-01-21,1ECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,879] INFO [widget_prim|task-0] Requested thread factory for connector MySqlConnector, id = widget_prim named = SignalProcessor (io.debezium.util.Threads:271)",1737441032.880625,"Jan 21, 2025 @ 07:30:32.880"
prim_kafka_connect-2025-01-21,1UCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,882] INFO [widget_prim|task-0] Requested thread factory for connector MySqlConnector, id = widget_prim named = change-event-source-coordinator (io.debezium.util.Threads:271)",1737441032.882136,"Jan 21, 2025 @ 07:30:32.882"
prim_kafka_connect-2025-01-21,1kCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,882] INFO [widget_prim|task-0] Requested thread factory for connector MySqlConnector, id = widget_prim named = blocking-snapshot (io.debezium.util.Threads:271)",1737441032.88269,"Jan 21, 2025 @ 07:30:32.882"
prim_kafka_connect-2025-01-21,10COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,883] INFO [widget_prim|task-0] Creating thread debezium-mysqlconnector-widget_prim-change-event-source-coordinator (io.debezium.util.Threads:288)",1737441032.883837,"Jan 21, 2025 @ 07:30:32.883"
prim_kafka_connect-2025-01-21,2ECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,887] INFO [widget_prim|task-0] SignalProcessor started. Scheduling it every 5000ms (io.debezium.pipeline.signal.SignalProcessor:105)",1737441032.890646,"Jan 21, 2025 @ 07:30:32.890"
prim_kafka_connect-2025-01-21,2UCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,887] INFO [widget_prim|task-0] Creating thread debezium-mysqlconnector-widget_prim-SignalProcessor (io.debezium.util.Threads:288)",1737441032.890724,"Jan 21, 2025 @ 07:30:32.890"
prim_kafka_connect-2025-01-21,2kCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,888] INFO [widget_prim|task-0] Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator:131)",1737441032.890758,"Jan 21, 2025 @ 07:30:32.890"
prim_kafka_connect-2025-01-21,20COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,888] INFO [widget_prim|task-0] Context created (io.debezium.pipeline.ChangeEventSourceCoordinator:134)",1737441032.89079,"Jan 21, 2025 @ 07:30:32.890"
prim_kafka_connect-2025-01-21,3ECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,889] INFO [widget_prim|task-0] A previous offset indicating a completed snapshot has been found. Neither schema nor data will be snapshotted. (io.debezium.connector.mysql.MySqlSnapshotChangeEventSource:102)",1737441032.890835,"Jan 21, 2025 @ 07:30:32.890"
prim_kafka_connect-2025-01-21,3UCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,889] INFO [widget_prim|task-0] Snapshot ended with SnapshotResult [status=SKIPPED, offset=MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=mysql-bin.231988, currentBinlogPosition=75274817, currentRowNumber=0, serverId=0, sourceTime=null, threadId=-1, currentQuery=null, tableIds=[], databaseName=null], snapshotCompleted=false, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=null, currentGtidSet=null, restartBinlogFilename=mysql-bin.231988, restartBinlogPosition=75274817, restartRowsToSkip=1, restartEventsToSkip=0, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] (io.debezium.pipeline.ChangeEventSourceCoordinator:254)",1737441032.890879,"Jan 21, 2025 @ 07:30:32.890"
prim_kafka_connect-2025-01-21,3kCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,889] INFO [widget_prim|task-0] Requested thread factory for connector MySqlConnector, id = widget_prim named = binlog-client (io.debezium.util.Threads:271)",1737441032.890953,"Jan 21, 2025 @ 07:30:32.890"
prim_kafka_connect-2025-01-21,30COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,892] INFO [widget_prim|task-0] WorkerSourceTask{id=widget_prim-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:279)",1737441032.893637,"Jan 21, 2025 @ 07:30:32.893"
prim_kafka_connect-2025-01-21,4ECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,900] INFO [widget_prim|task-0] Starting streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:271)",1737441032.902648,"Jan 21, 2025 @ 07:30:32.902"
prim_kafka_connect-2025-01-21,4UCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,900] INFO [widget_prim|task-0] Skip 0 events on streaming start (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:937)",1737441032.902742,"Jan 21, 2025 @ 07:30:32.902"
prim_kafka_connect-2025-01-21,4kCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,900] INFO [widget_prim|task-0] Skip 1 rows on streaming start (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:941)",1737441032.90278,"Jan 21, 2025 @ 07:30:32.902"
prim_kafka_connect-2025-01-21,40COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,900] INFO [widget_prim|task-0] Creating thread debezium-mysqlconnector-widget_prim-binlog-client (io.debezium.util.Threads:288)",1737441032.902812,"Jan 21, 2025 @ 07:30:32.902"
prim_kafka_connect-2025-01-21,5ECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,909] INFO [widget_prim|task-0] Creating thread debezium-mysqlconnector-widget_prim-binlog-client (io.debezium.util.Threads:288)",1737441032.90999,"Jan 21, 2025 @ 07:30:32.909"
prim_kafka_connect-2025-01-21,50COh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,935] INFO [widget_prim|task-0] Connected to binlog at 51.144.186.240:33059, starting at MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=mysql-bin.231988, currentBinlogPosition=75274817, currentRowNumber=0, serverId=0, sourceTime=null, threadId=-1, currentQuery=null, tableIds=[], databaseName=null], snapshotCompleted=false, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=null, currentGtidSet=null, restartBinlogFilename=mysql-bin.231988, restartBinlogPosition=75274817, restartRowsToSkip=1, restartEventsToSkip=0, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]] (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:1119)",1737441032.937558,"Jan 21, 2025 @ 07:30:32.937"
prim_kafka_connect-2025-01-21,6ECOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,938] INFO [widget_prim|task-0] Waiting for keepalive thread to start (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:958)",1737441032.938939,"Jan 21, 2025 @ 07:30:32.938"
prim_kafka_connect-2025-01-21,6UCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:32,944] INFO [widget_prim|task-0] Creating thread debezium-mysqlconnector-widget_prim-binlog-client (io.debezium.util.Threads:288)",1737441032.945129,"Jan 21, 2025 @ 07:30:32.945"
prim_kafka_connect-2025-01-21,6kCOh5QBTi1R4RdCUmPz,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:30:33,039] INFO [widget_prim|task-0] Keepalive thread is running (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:965)",1737441033.039222,"Jan 21, 2025 @ 07:30:33.039"
prim_kafka_connect-2025-01-21,JUCOh5QBTi1R4RdCyGSI,1,1,3,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,926] ERROR [widget_prim|task-0] Error during binlog processing. Last offset stored = {transaction_id=null, file=mysql-bin.232001, pos=18468800, server_id=1011001, event=1}, binlog reader near position = mysql-bin.232001/18468800 (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:1043)",1737441064.926816,"Jan 21, 2025 @ 07:31:04.926"
prim_kafka_connect-2025-01-21,JkCOh5QBTi1R4RdCyGSI,1,1,3,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,927] ERROR [widget_prim|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52)
io.debezium.DebeziumException: Error processing binlog event
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:298)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$30(MySqlStreamingChangeEventSource.java:876)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1263)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1089)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648)
        at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949)
        at java.base/java.lang.Thread.run(Thread.java:840)
Caused by: java.lang.NullPointerException: Cannot invoke ""java.util.List.iterator()"" because the return value of ""java.util.Map.get(Object)"" is null
        at io.debezium.antlr.DataTypeResolver.resolveDataType(DataTypeResolver.java:54)
        at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:147)
        at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.enterColumnDefinition(ColumnDefinitionParserListener.java:75)
        at io.debezium.ddl.parser.mysql.generated.MySqlParser$ColumnDefinitionContext.enterRule(MySqlParser.java:8955)
        at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46)
        at io.debezium.connector.mysql.antlr.listener.MySqlAntlrDdlParserListener.enterEveryRule(MySqlAntlrDdlParserListener.java:89)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:49)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:33)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:83)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:213)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:199)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:508)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$18(MySqlStreamingChangeEventSource.java:846)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:278)
        ... 6 more",1737441064.927794,"Jan 21, 2025 @ 07:31:04.927"
prim_kafka_connect-2025-01-21,J0COh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,928] INFO [widget_prim|task-0] Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:303)",1737441064.928133,"Jan 21, 2025 @ 07:31:04.928"
prim_kafka_connect-2025-01-21,KECOh5QBTi1R4RdCyGSI,1,1,3,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,960] ERROR [widget_prim|task-0] WorkerSourceTask{id=widget_prim-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)
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:67)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:298)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$30(MySqlStreamingChangeEventSource.java:876)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1263)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1089)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648)
        at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949)
        at java.base/java.lang.Thread.run(Thread.java:840)
Caused by: io.debezium.DebeziumException: Error processing binlog event
        ... 7 more
Caused by: java.lang.NullPointerException: Cannot invoke ""java.util.List.iterator()"" because the return value of ""java.util.Map.get(Object)"" is null
        at io.debezium.antlr.DataTypeResolver.resolveDataType(DataTypeResolver.java:54)
        at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:147)
        at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.enterColumnDefinition(ColumnDefinitionParserListener.java:75)
        at io.debezium.ddl.parser.mysql.generated.MySqlParser$ColumnDefinitionContext.enterRule(MySqlParser.java:8955)
        at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46)
        at io.debezium.connector.mysql.antlr.listener.MySqlAntlrDdlParserListener.enterEveryRule(MySqlAntlrDdlParserListener.java:89)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:49)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:33)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
        at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:83)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:213)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:199)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:508)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$18(MySqlStreamingChangeEventSource.java:846)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:278)
        ... 6 more",1737441064.961632,"Jan 21, 2025 @ 07:31:04.961"
prim_kafka_connect-2025-01-21,KUCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,960] INFO [widget_prim|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask:282)",1737441064.961871,"Jan 21, 2025 @ 07:31:04.961"
prim_kafka_connect-2025-01-21,LECOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,991] INFO [widget_prim|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:273)",1737441064.992481,"Jan 21, 2025 @ 07:31:04.992"
prim_kafka_connect-2025-01-21,LUCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,992] INFO [widget_prim|task-0] Stopped reading binlog after 0 events, last recorded offset: {transaction_id=null, file=mysql-bin.232001, pos=23481018, server_id=1011001, event=1} (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:1104)",1737441064.992598,"Jan 21, 2025 @ 07:31:04.992"
prim_kafka_connect-2025-01-21,LkCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,993] INFO [widget_prim|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor:127)",1737441064.993267,"Jan 21, 2025 @ 07:31:04.993"
prim_kafka_connect-2025-01-21,L0COh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,993] INFO [widget_prim|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry:105)",1737441064.993714,"Jan 21, 2025 @ 07:31:04.993"
prim_kafka_connect-2025-01-21,MECOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,995] INFO [widget_prim|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:949)",1737441064.995892,"Jan 21, 2025 @ 07:31:04.995"
prim_kafka_connect-2025-01-21,MUCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,996] INFO [widget_prim|task-0] [Producer clientId=widget_prim-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1373)",1737441064.996452,"Jan 21, 2025 @ 07:31:04.996"
prim_kafka_connect-2025-01-21,MkCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,999] INFO [widget_prim|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684)",1737441065.000748,"Jan 21, 2025 @ 07:31:05.000"
prim_kafka_connect-2025-01-21,M0COh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,999] INFO [widget_prim|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688)",1737441065.000839,"Jan 21, 2025 @ 07:31:05.000"
prim_kafka_connect-2025-01-21,NECOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:04,999] INFO [widget_prim|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688)",1737441065.000877,"Jan 21, 2025 @ 07:31:05.000"
prim_kafka_connect-2025-01-21,NUCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,000] INFO [widget_prim|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694)",1737441065.000916,"Jan 21, 2025 @ 07:31:05.000"
prim_kafka_connect-2025-01-21,NkCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,000] INFO [widget_prim|task-0] App info kafka.producer for widget_prim-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:88)",1737441065.00096,"Jan 21, 2025 @ 07:31:05.000"
prim_kafka_connect-2025-01-21,N0COh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,000] INFO [widget_prim|task-0] [Producer clientId=connector-producer-widget_prim-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1373)",1737441065.000996,"Jan 21, 2025 @ 07:31:05.000"
prim_kafka_connect-2025-01-21,OECOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,003] INFO [widget_prim|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684)",1737441065.003746,"Jan 21, 2025 @ 07:31:05.003"
prim_kafka_connect-2025-01-21,OUCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,003] INFO [widget_prim|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688)",1737441065.00384,"Jan 21, 2025 @ 07:31:05.003"
prim_kafka_connect-2025-01-21,OkCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,003] INFO [widget_prim|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688)",1737441065.003886,"Jan 21, 2025 @ 07:31:05.003"
prim_kafka_connect-2025-01-21,O0COh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,003] INFO [widget_prim|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694)",1737441065.003922,"Jan 21, 2025 @ 07:31:05.003"
prim_kafka_connect-2025-01-21,PECOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,004] INFO [widget_prim|task-0] App info kafka.producer for connector-producer-widget_prim-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:88)",1737441065.004159,"Jan 21, 2025 @ 07:31:05.004"
prim_kafka_connect-2025-01-21,PUCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,004] INFO [widget_prim|task-0] App info kafka.admin.client for connector-adminclient-widget_prim-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:88)",1737441065.005305,"Jan 21, 2025 @ 07:31:05.005"
prim_kafka_connect-2025-01-21,PkCOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,004] INFO [widget_prim|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684)",1737441065.005402,"Jan 21, 2025 @ 07:31:05.005"
prim_kafka_connect-2025-01-21,P0COh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,005] INFO [widget_prim|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688)",1737441065.005444,"Jan 21, 2025 @ 07:31:05.005"
prim_kafka_connect-2025-01-21,QECOh5QBTi1R4RdCyGSI,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:31:05,005] INFO [widget_prim|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694)",1737441065.005485,"Jan 21, 2025 @ 07:31:05.005"
prim_kafka_connect-2025-01-21,'kCbh5QBTi1R4RdC72Y,1,1,6,kafka-connect.service,prim-kafka-connect-zasis-prod-1,"[2025-01-21 06:45:26,846] INFO [widget_prim|task-0] Stopping task widget_prim-0 (org.apache.kafka.connect.runtime.Worker:1047)",1737441926.847676,"Jan 21, 2025 @ 07:45:26.847"

How to reproduce the issue using our tutorial deployment?

not yet - will try, but infra constraints makes it harder/nearly imposibble.

Feature request or enhancement

For feature requests or enhancements, provide this information, please:

Which use case/requirement will be addressed by the proposed feature?

<Your answer>

Implementation ideas (optional)

<Your answer>