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

Upgrade to Apache Kafka Connect 2.6.1

XMLWordPrintable

    • Icon: Task Task
    • Resolution: Done
    • Icon: Critical Critical
    • 1.4.1.Final
    • 1.3.0.Final
    • dependencies
    • None

      org.apache.kafka.connect.errors.ConnectException: org.apache.kafka.common.config.ConfigException: Unknown configuration 'transforms.Reroute.type'
      	at org.apache.kafka.connect.runtime.ConnectorConfig.transformations(ConnectorConfig.java:296)
      	at org.apache.kafka.connect.runtime.Worker.buildWorkerTask(Worker.java:605)
      	at org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:555)
      	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:1251)
      	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$1700(DistributedHerder.java:127)
      	at org.apache.kafka.connect.runtime.distributed.DistributedHerder$9.call(DistributedHerder.java:1014)
      	at org.apache.kafka.connect.runtime.distributed.DistributedHerder$9.call(DistributedHerder.java:995)
      	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:365)
      	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:294)
      	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:834)
      Caused by: org.apache.kafka.common.config.ConfigException: Unknown configuration 'transforms.Reroute.type'
      	at org.apache.kafka.common.config.AbstractConfig.get(AbstractConfig.java:159)
      	at org.apache.kafka.connect.runtime.SourceConnectorConfig$EnrichedSourceConnectorConfig.get(SourceConnectorConfig.java:57)
      	at org.apache.kafka.connect.runtime.SourceConnectorConfig.get(SourceConnectorConfig.java:141)
      	at org.apache.kafka.common.config.AbstractConfig.getClass(AbstractConfig.java:216)
      	at org.apache.kafka.connect.runtime.ConnectorConfig.transformations(ConnectorConfig.java:281)
      	... 13 more 

        

      connector.class=io.debezium.connector.mysql.MySqlConnector
      snapshot.locking.mode=none
      topic.creation.default.partitions=10
      tasks.max=1
      database.history.kafka.topic=....
      transforms.Reroute.key.enforce.uniqueness=true
      transforms=Reroute
      transforms.Reroute.topic.replacement=$1.$2
      decimal.handling.mode=string
      topic.creation.default.replication.factor=1
      transforms.Reroute.type=io.debezium.transforms.ByLogicalTableRouter
      database.user=cdc
      topic.creation.default.cleanup.policy=compact
      database.server.name=...
      topic.creation.default.retention.ms=7776000000
      transforms.Reroute.topic.regex=(.*)\.(.*)\.(.*)
      database.port=3306
      database.hostname=...
      snapshot.mode=when_needed 

      After removing `topic.creation.default.*` options it work fine.

              jpechane Jiri Pechanec
              pawel.wilczynski@fieldaware.com Paweł Wilczyński (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: