Uploaded image for project: 'Managed Service - Connectors'
  1. Managed Service - Connectors
  2. MGDCTRS-1870

Debezium Mysql connector - schema.history.internal.kafka.topic required

This issue belongs to an archived project. You can view it, but you can't modify it. Learn more

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Blocker Blocker
    • rhoc-la
    • None
    • debezium, strimzi
    • None
    • Very Likely
    • 0

      The connector seems to end in running state, but following error is present in the pod logs and the connector is not consuming any messages:

      2023-01-17 09:19:34,781 ERROR [mctr-cf36fej1mrprabr6r1d0|task-0] The 'schema.history.internal.kafka.topic' value is invalid: A value is required (io.debezium.storage.kafka.history.KafkaSchemaHistory) [task-thread-mctr-cf36fej1mrprabr6r1d0-0]
      2023-01-17 09:19:34,781 ERROR [mctr-cf36fej1mrprabr6r1d0|task-0] The 'schema.history.internal.kafka.bootstrap.servers' value is invalid: A value is required (io.debezium.storage.kafka.history.KafkaSchemaHistory) [task-thread-mctr-cf36fej1mrprabr6r1d0-0]
      2023-01-17 09:19:34,782 ERROR [mctr-cf36fej1mrprabr6r1d0|task-0] WorkerSourceTask{id=mctr-cf36fej1mrprabr6r1d0-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) [task-thread-mctr-cf36fej1mrprabr6r1d0-0]
      org.apache.kafka.connect.errors.ConnectException: Error configuring an instance of KafkaSchemaHistory; check the logs for details
      	at io.debezium.storage.kafka.history.KafkaSchemaHistory.configure(KafkaSchemaHistory.java:209)
      	at io.debezium.relational.HistorizedRelationalDatabaseConnectorConfig.getSchemaHistory(HistorizedRelationalDatabaseConnectorConfig.java:115)
      	at io.debezium.relational.HistorizedRelationalDatabaseSchema.<init>(HistorizedRelationalDatabaseSchema.java:41)
      	at io.debezium.connector.mysql.MySqlDatabaseSchema.<init>(MySqlDatabaseSchema.java:81)
      	at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:88)
      	at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:136)
      	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.initializeAndStart(AbstractWorkerSourceTask.java:270)
      	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:187)
      	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:244)
      	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:72)
      	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
      	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
      	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
      	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
      	at java.base/java.lang.Thread.run(Thread.java:829)
      

            anmohant Anisha Mohanty
            tplevko@redhat.com Tomas Plevko
            Archiver:
            ranumula@redhat.com Raju Anumula

              Created:
              Updated:
              Resolved:
              Archived: