Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-447

Task restart triggers MBean to register twice

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Minor Minor
    • 0.6.2
    • None
    • mysql-connector
    • None
    • Hide

      You can reproduce this by forcing the connector task to restart using the KC REST API.

      POST /connectors/dbz_connector_1/tasks/0/restart

      Show
      You can reproduce this by forcing the connector task to restart using the KC REST API. POST /connectors/dbz_connector_1/tasks/0/restart

      Seeing the following WARN message in the logs whenever the connector task restarts. I believe it's benign, but it seems to be attempting to register the JMX bean twice.

      [2017-11-08 11:38:25,238] INFO Kafka version : 0.11.0.0-cp1 (org.apache.kafka.common.utils.AppInfoParser:83)
      [2017-11-08 11:38:25,238] INFO Kafka commitId : 5cadaa94d0a69e0d (org.apache.kafka.common.utils.AppInfoParser:84)
      [2017-11-08 11:38:25,239] INFO Discovered coordinator 192.168.70.42:9092 (id: 2147483647 rack: null) for group iready_dbz-dbhistory. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:597)
      [2017-11-08 11:38:25,240] INFO Revoking previously assigned partitions [] for group iready_dbz-dbhistory (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:419)
      [2017-11-08 11:38:25,240] INFO (Re-)joining group iready_dbz-dbhistory (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:432)
      [2017-11-08 11:38:25,242] INFO Successfully joined group iready_dbz-dbhistory with generation 7 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:399)
      [2017-11-08 11:38:25,242] INFO Setting newly assigned partitions [dbhistory.iready-0] for group iready_dbz-dbhistory (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:262)
      [2017-11-08 11:38:25,690] INFO Step 0: Get all known binlogs from MySQL (io.debezium.connector.mysql.MySqlConnectorTask:285)
      [2017-11-08 11:38:25,692] INFO MySQL has the binlog file 'mysql-bin.000018' required by the connector (io.debezium.connector.mysql.MySqlConnectorTask:300)
      *[2017-11-08 11:38:25,693] WARN Error while register the MBean 'debezium.mysql:type=connector-metrics,context=binlog,server=dbserver1': MXBean already registered with name debezium.mysql:type=connector-metrics,context=binlog,server=dbserver1 (io.debezium.connector.mysql.BinlogReader:35)*
      [2017-11-08 11:38:25,696] INFO Connected to MySQL binlog at localhost:3306, starting at binlog file 'mysql-bin.000018', pos=120, skipping 0 events plus 0 rows (io.debezium.connector.mysql.BinlogReader:706)
      [2017-11-08 11:38:25,696] INFO Source task WorkerSourceTask{id=iready_dbz-0} finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:143)
      

            jpechane Jiri Pechanec
            pgoransson@cainc.com Peter Goransson (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: