-
Bug
-
Resolution: Done
-
Major
-
None
-
1.3.0.Final
-
None
-
False
-
False
-
Undefined
-
-
Debezium 1.3.0.Final , creating a connector for postgresdb to Kafka with SMT & topic custom creation settings combined - Connector gets created & then fails with the following error
2020-11-02 14:24:13,387 ERROR || Failed to start task connectorTesting5-0 [org.apache.kafka.connect.runtime.Worker]
org.apache.kafka.connect.errors.ConnectException: org.apache.kafka.common.config.ConfigException: Unknown configuration 'transforms.unwrap.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$10.call(DistributedHerder.java:1266)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder$10.call(DistributedHerder.java:1262)
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.unwrap.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)
... 10 more
As mentioned in one of the closed jiras, issue appears to be linked to https://issues.apache.org/jira/browse/KAFKA-10387 . Which was fixed in Kafka-Connect versions 2.6.1 and above. Debezium 1.0.3.Final currently appears to have Kafka-Connect
"version": "2.6.0"