Hi Srikrishna, The issue is that you are using "name" to specify the field name for the struct's fields. The correct key to use is "field".
Best, Shikhar On Thu, Sep 15, 2016 at 4:23 PM Gwen Shapira <g...@confluent.io> wrote: > ah, never mind - I just noticed you do use a schema... Maybe you are > running into this? https://issues.apache.org/jira/browse/KAFKA-3055 > > On Thu, Sep 15, 2016 at 4:20 PM, Gwen Shapira <g...@confluent.io> wrote: > > Most people use JSON without schema, so you should probably change > > your configuration to: > > > > key.converter.schemas.enable=false > > value.converter.schemas.enable=false > > > > On Thu, Sep 15, 2016 at 4:04 PM, Srikrishna Alla > > <allasrikrish...@gmail.com> wrote: > >> I am trying to use jdbc connector to send records from Kafka 0.9 to DB. > I > >> am using jsonConverter to convert the records. My connector is failing > when > >> its checking the Schema I am using. Please let me know what is the issue > >> with my json schema. > >> > >> Configuration used: > >> key.converter=org.apache.kafka.connect.storage.StringConverter > >> value.converter=org.apache.kafka.connect.json.JsonConverter > >> # Converter-specific settings can be passed in by prefixing the > Converter's > >> setting with the converter we want to apply > >> # it to > >> key.converter.schemas.enable=true > >> value.converter.schemas.enable=true > >> > >> Record that has been sent to the topic - > >> > {"schema":{"type":"struct","fields":[{"name":"error_code","type":"string","optional":"false"},{"name":"error_time","type":"string","optional":"false"},{"name":"error_msg","type":"string","optional":"false"},{"name":"source","type":"string","optional":"false"},{"name":"criticality","type":"string","optional":"false"}]},"payload":{"error_code":"RAW104","error_time":"09/15/2016@18 > :00:32","error_msg":"Not > >> accepting","source":"APPLICATION","criticality":"WARN"}} > >> > >> > >> Error I am seeing: > >> [2016-09-15 18:01:07,513] ERROR Thread WorkerSinkTask-jdbc-sink-test-0 > >> exiting with uncaught exception: > >> (org.apache.kafka.connect.util.ShutdownableThread:84) > >> *org.apache.kafka.connect.errors.DataException: Struct schema's field > name > >> not specified properly* > >> at > >> > org.apache.kafka.connect.json.JsonConverter.asConnectSchema(JsonConverter.java:493) > >> at > >> > org.apache.kafka.connect.json.JsonConverter.jsonToConnect(JsonConverter.java:344) > >> at > >> > org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:334) > >> at > >> > org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:266) > >> at > >> > org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:175) > >> at > >> > org.apache.kafka.connect.runtime.WorkerSinkTaskThread.iteration(WorkerSinkTaskThread.java:90) > >> at > >> > org.apache.kafka.connect.runtime.WorkerSinkTaskThread.execute(WorkerSinkTaskThread.java:58) > >> at > >> > org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82) > >> Exception in thread "WorkerSinkTask-jdbc-sink-test-0" > >> *org.apache.kafka.connect.errors.DataException: > >> Struct schema's field name not specified properly* > >> at > >> > org.apache.kafka.connect.json.JsonConverter.asConnectSchema(JsonConverter.java:493) > >> at > >> > org.apache.kafka.connect.json.JsonConverter.jsonToConnect(JsonConverter.java:344) > >> at > >> > org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:334) > >> at > >> > org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:266) > >> at > >> > org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:175) > >> at > >> > org.apache.kafka.connect.runtime.WorkerSinkTaskThread.iteration(WorkerSinkTaskThread.java:90) > >> at > >> > org.apache.kafka.connect.runtime.WorkerSinkTaskThread.execute(WorkerSinkTaskThread.java:58) > >> at > >> > org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82) > >> > >> Thanks, > >> Sri > > > > > > > > -- > > Gwen Shapira > > Product Manager | Confluent > > 650.450.2760 | @gwenshap > > Follow us: Twitter | blog > > > > -- > Gwen Shapira > Product Manager | Confluent > 650.450.2760 | @gwenshap > Follow us: Twitter | blog >
