-
Task
-
Resolution: Done
-
Critical
-
1.3.0.Final
-
None
-
False
-
False
-
Undefined
-
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.
- is duplicated by
-
DBZ-2731 Debezium connect: unable to use SMT with topic.creation.* properties
- Closed
-
DBZ-2992 Connector configuration error with transform and create topics options
- Closed
- relates to
-
DBZ-2719 Connector fails on creation- SMT and Topic custom creation settings do not work together
- Closed
- links to