amit cahanovich created KAFKA-12652:
---------------------------------------
Summary: connector doesnt accept transformation configuration
Key: KAFKA-12652
URL: https://issues.apache.org/jira/browse/KAFKA-12652
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Affects Versions: 2.7.0
Environment: ubuntu 20.04, strimzi
Reporter: amit cahanovich
connector configuration:
spec:
class: io.confluent.connect.jdbc.JdbcSourceConnector
tasksMax: 2
config:
connection.url:
${file:/opt/kafka/external-configuration/connector-config/kafka_secrets.properties:stg2_CONNECTION_URL}
schema.pattern:
${file:/opt/kafka/external-configuration/connector-config/kafka_secrets.properties:stg2_SCHEMA_PATERN}
connection.user:
${file:/opt/kafka/external-configuration/connector-config/kafka_secrets.properties:stg2_CONNECTION_USER}
connection.password:
${file:/opt/kafka/external-configuration/connector-config/kafka_secrets.properties:stg2_CONNECTION_PASSWORD}
mode: bulk
validate.non.null: false
table.types: TABLE
table.whitelist: jms_lib_source_of_lighting
topic.creation.default.replication.factor: 1
topic.creation.default.partitions: 1
transforms: MakeMap, InsertSource
transforms.MakeMap.type: org.apache.kafka.connect.transforms.HoistField$Value
transforms.MakeMap.field: line
transforms.InsertSource.type:
org.apache.kafka.connect.transforms.InsertField$Value
transforms.InsertSource.static.field: data_source
transforms.InsertSource.static.value: test-file-source
error:
value.converter = null
(org.apache.kafka.connect.runtime.SourceConnectorConfig$EnrichedSourceConnectorConfig)
[StartAndStopExecutor-connect-1-2]
2021-04-11 08:37:40,735 ERROR Failed to start task jdbc-mssql-connectora-0
(org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2]
org.apache.kafka.connect.errors.ConnectException:
org.apache.kafka.common.config.ConfigException: Unknown configuration
'transforms.MakeMap.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.MakeMap.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
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
