[
https://issues.apache.org/jira/browse/KAFKA-12652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-12652.
---------------------------------
Resolution: Duplicate
> connector doesnt accept transformation configuration
> ----------------------------------------------------
>
> Key: KAFKA-12652
> URL: https://issues.apache.org/jira/browse/KAFKA-12652
> Project: Kafka
> Issue Type: Bug
> Components: connect
> Affects Versions: 2.7.0
> Environment: ubuntu 20.04, strimzi
> Reporter: amit cahanovich
> Priority: Critical
>
> 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.20.10#820010)
