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)
