kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Randall Hauch (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-6513) New Connect header support doesn't define `converter.type` property correctly
Date Thu, 01 Feb 2018 00:44:03 GMT
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)

Mime
View raw message