[KAFKA-6513] New Connect header support doesn't define `converter.type` property correctly

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.1.0
• Fix Version/s: 1.1.0, 2.0.0
• Component/s: connect
• Assignee: Randall Hauch
• Reporter: Randall Hauch
• Created: 01/Feb/18 00:43
• Updated: 25/Apr/18 09:42
• Resolved: 09/Feb/18 23:48

Description

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:

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)

Issue Links

• links to: GitHub Pull Request #4512