Hi,
I'm trying to use the Confluent JDBC Sink as Sri is doing but without a schema.
I do not want to write "schema" + "payload" for each record as my
records are all for the same table and the schema is not going to
change (this is a very simple project)
is there a way to configure a fixed schema
Hi,
I'm trying to use the Confluent JDBC Sink as Sri is doing but without a schema.
I do not want to write "schema" + "payload" for each record as my records are
all for the same table and the schema is not going to change (this is a very
simple project)
Thanks
Enrico
Il giorno lun, 19/09/20
Thanks Shikar. I made this change and it's working now.
Thanks,
Sri
> On Sep 19, 2016, at 2:25 PM, Shikhar Bhushan wrote:
>
> 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,
>
> Shikh
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 wrote:
> ah, never mind - I just noticed you do use a schema... Maybe you are
> running into t
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 wrote:
> Most people use JSON without schema, so you should probably change
> your configuration to:
>
> key.conve
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
wrote:
> I am trying to use jdbc connector to send records from Kafka 0.9 to DB. I
>
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.con
