Randall Hauch created KAFKA-6513: ------------------------------------ Summary: New Connect header support doesn't define `converter.type` property correctly Key: KAFKA-6513 URL: https://issues.apache.org/jira/browse/KAFKA-6513 Project: Kafka Issue Type: Bug Components: KafkaConnect Affects Versions: 1.1.0 Reporter: Randall Hauch Assignee: Randall Hauch Fix For: 1.1.0
The recent feature (KAFKA-5142) added a new {{converter.type}} to make the {{Converter}} implementations now implement {{Configurable}}. However, the worker is not correctly setting these new property types and is instead incorrectly assuming the existing {{Converter}} implementations will set them. For example: {noformat} Exception in thread "main" org.apache.kafka.common.config.ConfigException: Missing required configuration "converter.type" which has no default value. at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:472) at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:462) at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:62) at org.apache.kafka.connect.storage.ConverterConfig.<init>(ConverterConfig.java:48) at org.apache.kafka.connect.json.JsonConverterConfig.<init>(JsonConverterConfig.java:59) at org.apache.kafka.connect.json.JsonConverter.configure(JsonConverter.java:284) at org.apache.kafka.connect.runtime.isolation.Plugins.newConfiguredPlugin(Plugins.java:77) at org.apache.kafka.connect.runtime.isolation.Plugins.newConverter(Plugins.java:208) at org.apache.kafka.connect.runtime.Worker.<init>(Worker.java:107) at io.confluent.connect.replicator.ReplicatorApp.config(ReplicatorApp.java:104) at io.confluent.connect.replicator.ReplicatorApp.main(ReplicatorApp.java:60) {noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)