[
https://issues.apache.org/jira/browse/KAFKA-6513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6513.
------------------------------------------
Resolution: Fixed
Fix Version/s: 1.2.0
Issue resolved by pull request 4512
[https://github.com/apache/kafka/pull/4512]
> 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
> Priority: Blocker
> Fix For: 1.2.0, 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)
