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

Snapshotter SPI wrongly loaded on Debezium Server

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • 2.6.0.Alpha2
    • None
    • core-library
    • None
    • False
    • None
    • False

    Description

      2024-02-12 15:22:06,641 ERROR [io.deb.ser.ConnectorLifecycle] (pool-6-thread-1) Connector completed: success = 'false', message = 'Unable to initialize and start connector's task class 'io.debezium.connector.postgresql.PostgresConnectorTask' with config: {connector.class=io.debezium.connector.postgresql.PostgresConnector, transforms=addheader, schema.include.list=inventory, offset.storage.redis.address=localhost:32778, topic.prefix=testc, offset.storage.file.filename=, errors.retry.delay.initial.ms=300, value.converter=org.apache.kafka.connect.json.JsonConverter, key.converter=org.apache.kafka.connect.json.JsonConverter, schema.history.internal.redis.address=localhost:32778, database.user=postgres, database.dbname=postgres, offset.storage=io.debezium.server.redis.RedisOffsetBackingStore, transforms.addheader.type=org.apache.kafka.connect.transforms.InsertHeader, offset.flush.timeout.ms=5000, errors.retry.delay.max.ms=10000, database.port=32779, offset.flush.interval.ms=0, errors.max.retries=-1, database.hostname=localhost, transforms.addheader.value.literal=headerValue, database.password=********, name=redis, table.include.list=inventory.customers,inventory.redis_test,inventory.redis_test2, transforms.addheader.header=headerKey}', error = 'java.lang.NullPointerException: Cannot invoke "io.debezium.connector.mysql.MySqlConnectorConfig.getConnectorAdapter()" because "config" is null': java.lang.NullPointerException: Cannot invoke "io.debezium.connector.mysql.MySqlConnectorConfig.getConnectorAdapter()" because "config" is null
          at io.debezium.connector.mysql.snapshot.mode.BeanAwareSnapshotter.getConnectionClass(BeanAwareSnapshotter.java:26)
          at io.debezium.connector.mysql.snapshot.mode.InitialSnapshotter.validate(InitialSnapshotter.java:40)
          at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:159)
          at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:141)
          at io.debezium.embedded.EmbeddedEngine.startSourceTask(EmbeddedEngine.java:638)
          at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:457)
          at io.debezium.embedded.ConvertingEngineBuilder$1.run(ConvertingEngineBuilder.java:248)
          at io.debezium.server.DebeziumServer.lambda$start$1(DebeziumServer.java:170)
          at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
          at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
          at java.base/java.lang.Thread.run(Thread.java:833) 

      Attachments

        Activity

          People

            rh-ee-mvitale Mario Fiore Vitale
            rh-ee-mvitale Mario Fiore Vitale
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: