Debezium Stopped Working

423 views
Skip to first unread message

Avinash Gupta

unread,
Sep 21, 2022, 3:13:30 PM9/21/22
to debezium
Hello All,

We are using debezium in our prod setup. yesterday all of sudden we see debezium process got shutdown with below error.

Can some please review below logs and suggest what could be the error here.

Sep 21, 2022 @ 22:33:16.685     -      WorkerSourceTask{id=tpbinge-prod-mysql-connector-0} Either no records were produced by the task since the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. (org.apache.kafka.connect.runtime.WorkerSourceTask:484)\n","stream":"stdout","time":"2022-09-21T17:03:16.68545653Z"}
    Sep 21, 2022 @ 22:33:23.024     -      Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:67)\n","stream":"stdout","time":"2022-09-21T17:03:23.024131902Z"}
    Sep 21, 2022 @ 22:33:23.025     -      node0 Stopped scavenging (org.eclipse.jetty.server.session:149)\n","stream":"stdout","time":"2022-09-21T17:03:23.02466886Z"}
    Sep 21, 2022 @ 22:33:23.025     -      Stopped http_8083@26cb5207{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:381)\n","stream":"stdout","time":"2022-09-21T17:03:23.024601162Z"}
    Sep 21, 2022 @ 22:33:23.025     -      [Worker clientId=connect-1, groupId=connect-cluster] Herder stopping (org.apache.kafka.connect.runtime.distributed.DistributedHerder:731)\n","stream":"stdout","time":"2022-09-21T17:03:23.025563632Z"}
    Sep 21, 2022 @ 22:33:23.026     -      Stopping task tpbinge-prod-mysql-connector-0 (org.apache.kafka.connect.runtime.Worker:823)\n","stream":"stdout","time":"2022-09-21T17:03:23.026235664Z"}
    Sep 21, 2022 @ 22:33:23.026     -      Scheduled shutdown for WorkerConnector{id=tpbinge-prod-mysql-connector} (org.apache.kafka.connect.runtime.WorkerConnector:248)\n","stream":"stdout","time":"2022-09-21T17:03:23.026114917Z"}
    Sep 21, 2022 @ 22:33:23.026     -      Stopping connector tpbinge-prod-mysql-connector (org.apache.kafka.connect.runtime.Worker:376)\n","stream":"stdout","time":"2022-09-21T17:03:23.026067722Z"}
    Sep 21, 2022 @ 22:33:23.026     -      [Worker clientId=connect-1, groupId=connect-cluster] Stopping connectors and tasks that are still assigned to this worker. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:696)\n","stream":"stdout","time":"2022-09-21T17:03:23.025714224Z"}
    Sep 21, 2022 @ 22:33:23.039     -      Completed shutdown for WorkerConnector{id=tpbinge-prod-mysql-connector} (org.apache.kafka.connect.runtime.WorkerConnector:268)\n","stream":"stdout","time":"2022-09-21T17:03:23.039528557Z"}
    Sep 21, 2022 @ 22:33:23.446     -      WorkerSourceTask{id=tpbinge-prod-mysql-connector-0} Either no records were produced by the task since the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. (org.apache.kafka.connect.runtime.WorkerSourceTask:484)\n","stream":"stdout","time":"2022-09-21T17:03:23.446309869Z"}
    Sep 21, 2022 @ 22:33:23.448     -      Stopping down connector (io.debezium.connector.common.BaseSourceTask:238)\n","stream":"stdout","time":"2022-09-21T17:03:23.448779539Z"}
    Sep 21, 2022 @ 22:33:23.462     -      Stopped reading binlog after 0 events, last recorded offset: {transaction_id=null, ts_sec=1663779798, file=mysql-bin-changelog.076651, pos=2312651, server_id=-1, event=1} (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:1188)\n","stream":"stdout","time":"2022-09-21T17:03:23.462773987Z"}
    Sep 21, 2022 @ 22:33:23.462     -      Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:173)\n","stream":"stdout","time":"2022-09-21T17:03:23.462839907Z"}
    Sep 21, 2022 @ 22:33:23.464     -      Exception while closing JDBC connection (io.debezium.connector.mysql.MySqlConnectorTask:231)\n","stream":"stdout","time":"2022-09-21T17:03:23.464577695Z"}
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)\n","stream":"stdout","time":"2022-09-21T17:03:23.464601792Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.ConnectionImpl.close(ConnectionImpl.java:713)\n","stream":"stdout","time":"2022-09-21T17:03:23.464616176Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n","stream":"stdout","time":"2022-09-21T17:03:23.464625216Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.ConnectionImpl.rollback(ConnectionImpl.java:1837)\n","stream":"stdout","time":"2022-09-21T17:03:23.464610286Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.ConnectionImpl.realClose(ConnectionImpl.java:1694)\n","stream":"stdout","time":"2022-09-21T17:03:23.464613165Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at java.base/java.lang.Thread.run(Thread.java:829)\n","stream":"stdout","time":"2022-09-21T17:03:23.464631442Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"java.sql.SQLNonTransientConnectionException: Communications link failure during rollback(). Transaction resolution unknown.\n","stream":"stdout","time":"2022-09-21T17:03:23.46459423Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:110)\n","stream":"stdout","time":"2022-09-21T17:03:23.464598366Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:63)\n","stream":"stdout","time":"2022-09-21T17:03:23.464607446Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n","stream":"stdout","time":"2022-09-21T17:03:23.464622258Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:89)\n","stream":"stdout","time":"2022-09-21T17:03:23.464604595Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at io.debezium.jdbc.JdbcConnection.lambda$doClose$3(JdbcConnection.java:964)\n","stream":"stdout","time":"2022-09-21T17:03:23.464619095Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n","stream":"stdout","time":"2022-09-21T17:03:23.464628288Z"}     -
    Sep 21, 2022 @ 22:33:23.466     -      [Producer clientId=bingeipacs-dbhistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:23.464825702Z"}
    Sep 21, 2022 @ 22:33:23.467     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:23.46725327Z"}
    Sep 21, 2022 @ 22:33:23.468     -      App info kafka.producer for bingeipacs-dbhistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:23.46744507Z"}
    Sep 21, 2022 @ 22:33:23.468     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:23.467345223Z"}
    Sep 21, 2022 @ 22:33:23.468     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:23.467334435Z"}
    Sep 21, 2022 @ 22:33:23.468     -      [Producer clientId=connector-producer-tpbinge-prod-mysql-connector-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:23.467527042Z"}
    Sep 21, 2022 @ 22:33:23.469     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:23.469070672Z"}
    Sep 21, 2022 @ 22:33:23.470     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:23.469264078Z"}
    Sep 21, 2022 @ 22:33:23.470     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:23.469278088Z"}
    Sep 21, 2022 @ 22:33:23.470     -      App info kafka.producer for connector-producer-tpbinge-prod-mysql-connector-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:23.469284447Z"}
    Sep 21, 2022 @ 22:33:23.471     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:23.470894538Z"}
    Sep 21, 2022 @ 22:33:23.471     -      [Worker clientId=connect-1, groupId=connect-cluster] Resetting generation due to: consumer pro-actively leaving the group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:972)\n","stream":"stdout","time":"2022-09-21T17:03:23.470858828Z"}
    Sep 21, 2022 @ 22:33:23.471     -      [Worker clientId=connect-1, groupId=connect-cluster] Close timed out with 1 pending requests to coordinator, terminating client connections (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:1037)\n","stream":"stdout","time":"2022-09-21T17:03:23.47088952Z"}
    Sep 21, 2022 @ 22:33:23.471     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:23.470964091Z"}
    Sep 21, 2022 @ 22:33:23.471     -      [Worker clientId=connect-1, groupId=connect-cluster] Member connect-1-35138a2c-28b9-473d-b52b-9a4445b19053 sending LeaveGroup request to coordinator b-3.tpbingeprodmsk.uxse57.c3.kafka.ap-south-1.amazonaws.com:9098 (id: 2147483644 rack: null) due to the consumer is being closed (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:1060)\n","stream":"stdout","time":"2022-09-21T17:03:23.470409298Z"}
    Sep 21, 2022 @ 22:33:23.471     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:23.470946325Z"}
    Sep 21, 2022 @ 22:33:23.472     -      Stopping KafkaBasedLog for topic dbz3-connect-status (org.apache.kafka.connect.util.KafkaBasedLog:208)\n","stream":"stdout","time":"2022-09-21T17:03:23.47196349Z"}
    Sep 21, 2022 @ 22:33:23.472     -      App info kafka.connect for connect-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:23.471936814Z"}
    Sep 21, 2022 @ 22:33:23.472     -      [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:23.472127033Z"}
    Sep 21, 2022 @ 22:33:25.101     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.101071827Z"}
    Sep 21, 2022 @ 22:33:25.101     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.101038818Z"}
    Sep 21, 2022 @ 22:33:25.102     -      App info kafka.producer for producer-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.101310587Z"}
    Sep 21, 2022 @ 22:33:25.102     -      [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)\n","stream":"stdout","time":"2022-09-21T17:03:25.101617467Z"}
    Sep 21, 2022 @ 22:33:25.102     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.101714842Z"}
    Sep 21, 2022 @ 22:33:25.102     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.101156927Z"}
    Sep 21, 2022 @ 22:33:25.102     -      [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting generation due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:972)\n","stream":"stdout","time":"2022-09-21T17:03:25.101563139Z"}
    Sep 21, 2022 @ 22:33:25.102     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.101730868Z"}
    Sep 21, 2022 @ 22:33:25.102     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.101809029Z"}
    Sep 21, 2022 @ 22:33:25.103     -      App info kafka.consumer for consumer-connect-cluster-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.103318803Z"}
    Sep 21, 2022 @ 22:33:25.103     -      Stopped KafkaBasedLog for topic dbz3-connect-status (org.apache.kafka.connect.util.KafkaBasedLog:237)\n","stream":"stdout","time":"2022-09-21T17:03:25.103328775Z"}
    Sep 21, 2022 @ 22:33:25.104     -      [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:25.10366436Z"}
    Sep 21, 2022 @ 22:33:25.104     -      Closing KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:311)\n","stream":"stdout","time":"2022-09-21T17:03:25.103487724Z"}
    Sep 21, 2022 @ 22:33:25.104     -      Stopping KafkaBasedLog for topic dbz3-connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:208)\n","stream":"stdout","time":"2022-09-21T17:03:25.10349386Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.104760694Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.105078711Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.105134377Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.10470332Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.104712522Z"}
    Sep 21, 2022 @ 22:33:25.105     -      App info kafka.producer for producer-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.104829996Z"}
    Sep 21, 2022 @ 22:33:25.105     -      [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Resetting generation due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:972)\n","stream":"stdout","time":"2022-09-21T17:03:25.104994573Z"}
    Sep 21, 2022 @ 22:33:25.105     -      [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)\n","stream":"stdout","time":"2022-09-21T17:03:25.105000403Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.105096946Z"}
    Sep 21, 2022 @ 22:33:25.106     -      App info kafka.consumer for consumer-connect-cluster-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.105859239Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Worker stopping (org.apache.kafka.connect.runtime.Worker:199)\n","stream":"stdout","time":"2022-09-21T17:03:25.105922176Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Stopping KafkaBasedLog for topic dbz3-connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:208)\n","stream":"stdout","time":"2022-09-21T17:03:25.106125002Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Stopped KafkaBasedLog for topic dbz3-connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:237)\n","stream":"stdout","time":"2022-09-21T17:03:25.105870133Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Stopping KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:151)\n","stream":"stdout","time":"2022-09-21T17:03:25.10611151Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Closed KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:319)\n","stream":"stdout","time":"2022-09-21T17:03:25.105900415Z"}
    Sep 21, 2022 @ 22:33:25.107     -      [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting generation due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:972)\n","stream":"stdout","time":"2022-09-21T17:03:25.107273208Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.10748932Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.107107679Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.107046381Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.107056918Z"}
    Sep 21, 2022 @ 22:33:25.107     -      [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)\n","stream":"stdout","time":"2022-09-21T17:03:25.107281852Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.107378657Z"}
    Sep 21, 2022 @ 22:33:25.107     -      [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:25.106293914Z"}
    Sep 21, 2022 @ 22:33:25.107     -      App info kafka.producer for producer-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.107142479Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.107383283Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Stopped KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:159)\n","stream":"stdout","time":"2022-09-21T17:03:25.108290303Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.108332602Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.108371375Z"}
    Sep 21, 2022 @ 22:33:25.108     -      App info kafka.consumer for consumer-connect-cluster-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.108262543Z"}
    Sep 21, 2022 @ 22:33:25.108     -      App info kafka.connect for xx.xx.xx.xx:8083 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.108499725Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Worker stopped (org.apache.kafka.connect.runtime.Worker:220)\n","stream":"stdout","time":"2022-09-21T17:03:25.108544318Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Stopped KafkaBasedLog for topic dbz3-connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:237)\n","stream":"stdout","time":"2022-09-21T17:03:25.108269503Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.108337371Z"}
    Sep 21, 2022 @ 22:33:25.110     -      App info kafka.admin.client for adminclient-8 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.109450405Z"}
    Sep 21, 2022 @ 22:33:25.110     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.110124215Z"}
    Sep 21, 2022 @ 22:33:25.110     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.110151446Z"}
    Sep 21, 2022 @ 22:33:25.110     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.110133459Z"}
    Sep 21, 2022 @ 22:33:25.110     -      [Worker clientId=connect-1, groupId=connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:331)\n","stream":"stdout","time":"2022-09-21T17:03:25.110277875Z"}
    Sep 21, 2022 @ 22:33:25.111     -      [Worker clientId=connect-1, groupId=connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:751)\n","stream":"stdout","time":"2022-09-21T17:03:25.110991336Z"}
    Sep 21, 2022 @ 22:33:25.111     -      Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:72)\n","stream":"stdout","time":"2022-09-21T17:03:25.111000596Z"}Sep 21, 2022 @ 22:33:16.685     -      WorkerSourceTask{id=tpbinge-prod-mysql-connector-0} Either no records were produced by the task since the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. (org.apache.kafka.connect.runtime.WorkerSourceTask:484)\n","stream":"stdout","time":"2022-09-21T17:03:16.68545653Z"}
    Sep 21, 2022 @ 22:33:23.024     -      Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:67)\n","stream":"stdout","time":"2022-09-21T17:03:23.024131902Z"}
    Sep 21, 2022 @ 22:33:23.025     -      node0 Stopped scavenging (org.eclipse.jetty.server.session:149)\n","stream":"stdout","time":"2022-09-21T17:03:23.02466886Z"}
    Sep 21, 2022 @ 22:33:23.025     -      Stopped http_8083@26cb5207{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:381)\n","stream":"stdout","time":"2022-09-21T17:03:23.024601162Z"}
    Sep 21, 2022 @ 22:33:23.025     -      [Worker clientId=connect-1, groupId=connect-cluster] Herder stopping (org.apache.kafka.connect.runtime.distributed.DistributedHerder:731)\n","stream":"stdout","time":"2022-09-21T17:03:23.025563632Z"}
    Sep 21, 2022 @ 22:33:23.026     -      Stopping task tpbinge-prod-mysql-connector-0 (org.apache.kafka.connect.runtime.Worker:823)\n","stream":"stdout","time":"2022-09-21T17:03:23.026235664Z"}
    Sep 21, 2022 @ 22:33:23.026     -      Scheduled shutdown for WorkerConnector{id=tpbinge-prod-mysql-connector} (org.apache.kafka.connect.runtime.WorkerConnector:248)\n","stream":"stdout","time":"2022-09-21T17:03:23.026114917Z"}
    Sep 21, 2022 @ 22:33:23.026     -      Stopping connector tpbinge-prod-mysql-connector (org.apache.kafka.connect.runtime.Worker:376)\n","stream":"stdout","time":"2022-09-21T17:03:23.026067722Z"}
    Sep 21, 2022 @ 22:33:23.026     -      [Worker clientId=connect-1, groupId=connect-cluster] Stopping connectors and tasks that are still assigned to this worker. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:696)\n","stream":"stdout","time":"2022-09-21T17:03:23.025714224Z"}
    Sep 21, 2022 @ 22:33:23.039     -      Completed shutdown for WorkerConnector{id=tpbinge-prod-mysql-connector} (org.apache.kafka.connect.runtime.WorkerConnector:268)\n","stream":"stdout","time":"2022-09-21T17:03:23.039528557Z"}
    Sep 21, 2022 @ 22:33:23.446     -      WorkerSourceTask{id=tpbinge-prod-mysql-connector-0} Either no records were produced by the task since the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. (org.apache.kafka.connect.runtime.WorkerSourceTask:484)\n","stream":"stdout","time":"2022-09-21T17:03:23.446309869Z"}
    Sep 21, 2022 @ 22:33:23.448     -      Stopping down connector (io.debezium.connector.common.BaseSourceTask:238)\n","stream":"stdout","time":"2022-09-21T17:03:23.448779539Z"}
    Sep 21, 2022 @ 22:33:23.462     -      Stopped reading binlog after 0 events, last recorded offset: {transaction_id=null, ts_sec=1663779798, file=mysql-bin-changelog.076651, pos=2312651, server_id=-1, event=1} (io.debezium.connector.mysql.MySqlStreamingChangeEventSource:1188)\n","stream":"stdout","time":"2022-09-21T17:03:23.462773987Z"}
    Sep 21, 2022 @ 22:33:23.462     -      Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:173)\n","stream":"stdout","time":"2022-09-21T17:03:23.462839907Z"}
    Sep 21, 2022 @ 22:33:23.464     -      Exception while closing JDBC connection (io.debezium.connector.mysql.MySqlConnectorTask:231)\n","stream":"stdout","time":"2022-09-21T17:03:23.464577695Z"}
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)\n","stream":"stdout","time":"2022-09-21T17:03:23.464601792Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.ConnectionImpl.close(ConnectionImpl.java:713)\n","stream":"stdout","time":"2022-09-21T17:03:23.464616176Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n","stream":"stdout","time":"2022-09-21T17:03:23.464625216Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.ConnectionImpl.rollback(ConnectionImpl.java:1837)\n","stream":"stdout","time":"2022-09-21T17:03:23.464610286Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.ConnectionImpl.realClose(ConnectionImpl.java:1694)\n","stream":"stdout","time":"2022-09-21T17:03:23.464613165Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at java.base/java.lang.Thread.run(Thread.java:829)\n","stream":"stdout","time":"2022-09-21T17:03:23.464631442Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"java.sql.SQLNonTransientConnectionException: Communications link failure during rollback(). Transaction resolution unknown.\n","stream":"stdout","time":"2022-09-21T17:03:23.46459423Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:110)\n","stream":"stdout","time":"2022-09-21T17:03:23.464598366Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:63)\n","stream":"stdout","time":"2022-09-21T17:03:23.464607446Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n","stream":"stdout","time":"2022-09-21T17:03:23.464622258Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:89)\n","stream":"stdout","time":"2022-09-21T17:03:23.464604595Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at io.debezium.jdbc.JdbcConnection.lambda$doClose$3(JdbcConnection.java:964)\n","stream":"stdout","time":"2022-09-21T17:03:23.464619095Z"}     -
    Sep 21, 2022 @ 22:33:23.464    {"log":"\u0009at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n","stream":"stdout","time":"2022-09-21T17:03:23.464628288Z"}     -
    Sep 21, 2022 @ 22:33:23.466     -      [Producer clientId=bingeipacs-dbhistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:23.464825702Z"}
    Sep 21, 2022 @ 22:33:23.467     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:23.46725327Z"}
    Sep 21, 2022 @ 22:33:23.468     -      App info kafka.producer for bingeipacs-dbhistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:23.46744507Z"}
    Sep 21, 2022 @ 22:33:23.468     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:23.467345223Z"}
    Sep 21, 2022 @ 22:33:23.468     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:23.467334435Z"}
    Sep 21, 2022 @ 22:33:23.468     -      [Producer clientId=connector-producer-tpbinge-prod-mysql-connector-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:23.467527042Z"}
    Sep 21, 2022 @ 22:33:23.469     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:23.469070672Z"}
    Sep 21, 2022 @ 22:33:23.470     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:23.469264078Z"}
    Sep 21, 2022 @ 22:33:23.470     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:23.469278088Z"}
    Sep 21, 2022 @ 22:33:23.470     -      App info kafka.producer for connector-producer-tpbinge-prod-mysql-connector-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:23.469284447Z"}
    Sep 21, 2022 @ 22:33:23.471     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:23.470894538Z"}
    Sep 21, 2022 @ 22:33:23.471     -      [Worker clientId=connect-1, groupId=connect-cluster] Resetting generation due to: consumer pro-actively leaving the group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:972)\n","stream":"stdout","time":"2022-09-21T17:03:23.470858828Z"}
    Sep 21, 2022 @ 22:33:23.471     -      [Worker clientId=connect-1, groupId=connect-cluster] Close timed out with 1 pending requests to coordinator, terminating client connections (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:1037)\n","stream":"stdout","time":"2022-09-21T17:03:23.47088952Z"}
    Sep 21, 2022 @ 22:33:23.471     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:23.470964091Z"}
    Sep 21, 2022 @ 22:33:23.471     -      [Worker clientId=connect-1, groupId=connect-cluster] Member connect-1-35138a2c-28b9-473d-b52b-9a4445b19053 sending LeaveGroup request to coordinator b-3.tpbingeprodmsk.uxse57.c3.kafka.ap-south-1.amazonaws.com:9098 (id: 2147483644 rack: null) due to the consumer is being closed (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:1060)\n","stream":"stdout","time":"2022-09-21T17:03:23.470409298Z"}
    Sep 21, 2022 @ 22:33:23.471     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:23.470946325Z"}
    Sep 21, 2022 @ 22:33:23.472     -      Stopping KafkaBasedLog for topic dbz3-connect-status (org.apache.kafka.connect.util.KafkaBasedLog:208)\n","stream":"stdout","time":"2022-09-21T17:03:23.47196349Z"}
    Sep 21, 2022 @ 22:33:23.472     -      App info kafka.connect for connect-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:23.471936814Z"}
    Sep 21, 2022 @ 22:33:23.472     -      [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:23.472127033Z"}
    Sep 21, 2022 @ 22:33:25.101     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.101071827Z"}
    Sep 21, 2022 @ 22:33:25.101     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.101038818Z"}
    Sep 21, 2022 @ 22:33:25.102     -      App info kafka.producer for producer-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.101310587Z"}
    Sep 21, 2022 @ 22:33:25.102     -      [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)\n","stream":"stdout","time":"2022-09-21T17:03:25.101617467Z"}
    Sep 21, 2022 @ 22:33:25.102     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.101714842Z"}
    Sep 21, 2022 @ 22:33:25.102     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.101156927Z"}
    Sep 21, 2022 @ 22:33:25.102     -      [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting generation due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:972)\n","stream":"stdout","time":"2022-09-21T17:03:25.101563139Z"}
    Sep 21, 2022 @ 22:33:25.102     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.101730868Z"}
    Sep 21, 2022 @ 22:33:25.102     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.101809029Z"}
    Sep 21, 2022 @ 22:33:25.103     -      App info kafka.consumer for consumer-connect-cluster-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.103318803Z"}
    Sep 21, 2022 @ 22:33:25.103     -      Stopped KafkaBasedLog for topic dbz3-connect-status (org.apache.kafka.connect.util.KafkaBasedLog:237)\n","stream":"stdout","time":"2022-09-21T17:03:25.103328775Z"}
    Sep 21, 2022 @ 22:33:25.104     -      [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:25.10366436Z"}
    Sep 21, 2022 @ 22:33:25.104     -      Closing KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:311)\n","stream":"stdout","time":"2022-09-21T17:03:25.103487724Z"}
    Sep 21, 2022 @ 22:33:25.104     -      Stopping KafkaBasedLog for topic dbz3-connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:208)\n","stream":"stdout","time":"2022-09-21T17:03:25.10349386Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.104760694Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.105078711Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.105134377Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.10470332Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.104712522Z"}
    Sep 21, 2022 @ 22:33:25.105     -      App info kafka.producer for producer-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.104829996Z"}
    Sep 21, 2022 @ 22:33:25.105     -      [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Resetting generation due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:972)\n","stream":"stdout","time":"2022-09-21T17:03:25.104994573Z"}
    Sep 21, 2022 @ 22:33:25.105     -      [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)\n","stream":"stdout","time":"2022-09-21T17:03:25.105000403Z"}
    Sep 21, 2022 @ 22:33:25.105     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.105096946Z"}
    Sep 21, 2022 @ 22:33:25.106     -      App info kafka.consumer for consumer-connect-cluster-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.105859239Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Worker stopping (org.apache.kafka.connect.runtime.Worker:199)\n","stream":"stdout","time":"2022-09-21T17:03:25.105922176Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Stopping KafkaBasedLog for topic dbz3-connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:208)\n","stream":"stdout","time":"2022-09-21T17:03:25.106125002Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Stopped KafkaBasedLog for topic dbz3-connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:237)\n","stream":"stdout","time":"2022-09-21T17:03:25.105870133Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Stopping KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:151)\n","stream":"stdout","time":"2022-09-21T17:03:25.10611151Z"}
    Sep 21, 2022 @ 22:33:25.106     -      Closed KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:319)\n","stream":"stdout","time":"2022-09-21T17:03:25.105900415Z"}
    Sep 21, 2022 @ 22:33:25.107     -      [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting generation due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:972)\n","stream":"stdout","time":"2022-09-21T17:03:25.107273208Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.10748932Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.107107679Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.107046381Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.107056918Z"}
    Sep 21, 2022 @ 22:33:25.107     -      [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)\n","stream":"stdout","time":"2022-09-21T17:03:25.107281852Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.107378657Z"}
    Sep 21, 2022 @ 22:33:25.107     -      [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1228)\n","stream":"stdout","time":"2022-09-21T17:03:25.106293914Z"}
    Sep 21, 2022 @ 22:33:25.107     -      App info kafka.producer for producer-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.107142479Z"}
    Sep 21, 2022 @ 22:33:25.107     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.107383283Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Stopped KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:159)\n","stream":"stdout","time":"2022-09-21T17:03:25.108290303Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.108332602Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.108371375Z"}
    Sep 21, 2022 @ 22:33:25.108     -      App info kafka.consumer for consumer-connect-cluster-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.108262543Z"}
    Sep 21, 2022 @ 22:33:25.108     -      App info kafka.connect for xx.xx.xx.xx:8083 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.108499725Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Worker stopped (org.apache.kafka.connect.runtime.Worker:220)\n","stream":"stdout","time":"2022-09-21T17:03:25.108544318Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Stopped KafkaBasedLog for topic dbz3-connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:237)\n","stream":"stdout","time":"2022-09-21T17:03:25.108269503Z"}
    Sep 21, 2022 @ 22:33:25.108     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.108337371Z"}
    Sep 21, 2022 @ 22:33:25.110     -      App info kafka.admin.client for adminclient-8 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)\n","stream":"stdout","time":"2022-09-21T17:03:25.109450405Z"}
    Sep 21, 2022 @ 22:33:25.110     -      Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)\n","stream":"stdout","time":"2022-09-21T17:03:25.110124215Z"}
    Sep 21, 2022 @ 22:33:25.110     -      Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)\n","stream":"stdout","time":"2022-09-21T17:03:25.110151446Z"}
    Sep 21, 2022 @ 22:33:25.110     -      Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)\n","stream":"stdout","time":"2022-09-21T17:03:25.110133459Z"}
    Sep 21, 2022 @ 22:33:25.110     -      [Worker clientId=connect-1, groupId=connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:331)\n","stream":"stdout","time":"2022-09-21T17:03:25.110277875Z"}
    Sep 21, 2022 @ 22:33:25.111     -      [Worker clientId=connect-1, groupId=connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:751)\n","stream":"stdout","time":"2022-09-21T17:03:25.110991336Z"}
    Sep 21, 2022 @ 22:33:25.111     -      Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:72)\n","stream":"stdout","time":"2022-09-21T17:03:25.111000596Z"}




Thanks,
Avinash Gupta

Avinash Gupta

unread,
Sep 22, 2022, 7:08:47 AM9/22/22
to debezium
Hello All,

Can some one please help, i dont see much on the internet for this error.


Thanks,
Avinash 

Chris Cranford

unread,
Sep 22, 2022, 9:41:37 AM9/22/22
to debe...@googlegroups.com, Avinash Gupta
Hi Avinash -

I see two problems here, both of which may be a result of the same issue:

    - MySQL threw a communications link error, unable to resolve transaction state
    - Kafka Connect is disconnecting from the Kafka broker

Is it possible this is all due to poor network connectivity?

Chris
--
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/debezium/5573ab9c-59e2-4ccd-b1b6-d783985be672n%40googlegroups.com.

Avinash Gupta

unread,
Sep 22, 2022, 10:35:39 PM9/22/22
to debezium
Thanks Cris for the response.

We are analyzing the network if there was some poor connectivity.  but i hope Kafka connect connectivity issue with mysql & kafka  is not side effect of some other issue.

As per log kafka connect shutdown triggered post that we see connectivity issue.


Thanks,
Avinash Gupta

George H

unread,
Oct 11, 2022, 10:34:52 AM10/11/22
to debezium
Hi there,

My name is George form a recruitment consultancy in the UK.

We are recruiting for a Debezium Consultant for a remote working contract.

If you are interested or know anyone who has excellent Debezium experience please mail geo...@digisourced.com and rebecca...@recann.co.uk
Reply all
Reply to author
Forward
0 new messages