You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Nicolas Fouché <nf...@onfocus.io> on 2017/05/16 08:39:33 UTC

`key.converter` per connector

Hi,

In distributed mode, can I set `key.converter` in a connector
configuration. Some of my connectors use
`org.apache.kafka.connect.storage.StringConverter` while others would need
`io.confluent.connect.avro.AvroConverter`.

So I wondered if `key.converter` could be overriden at the connector level.

Thanks.

Re: `key.converter` per connector

Posted by Nicolas Fouché <nf...@onfocus.io>.

Awesome. Thanks Bharat.

2017-05-16 21:27 GMT+02:00 BigData dev <bi...@gmail.com>:

> Hi,
> key.converter and value.converter can be overridden at connector level.
> This has been supported  from Kafka 0.10.1.0
>
> For more info refer to this KIP
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-
> 75+-+Add+per-connector+Converters
>
>
> Thanks,
> Bharat
>
>
> On Tue, May 16, 2017 at 1:39 AM, Nicolas Fouché <nf...@onfocus.io>
> wrote:
>
> > Hi,
> >
> > In distributed mode, can I set `key.converter` in a connector
> > configuration. Some of my connectors use
> > `org.apache.kafka.connect.storage.StringConverter` while others would
> need
> > `io.confluent.connect.avro.AvroConverter`.
> >
> > So I wondered if `key.converter` could be overriden at the connector
> level.
> >
> > Thanks.
> >
>

Re: `key.converter` per connector

Posted by BigData dev <bi...@gmail.com>.

Hi,
key.converter and value.converter can be overridden at connector level.
This has been supported  from Kafka 0.10.1.0

For more info refer to this KIP
https://cwiki.apache.org/confluence/display/KAFKA/KIP-75+-+Add+per-connector+Converters


Thanks,
Bharat


On Tue, May 16, 2017 at 1:39 AM, Nicolas Fouché <nf...@onfocus.io> wrote:

> Hi,
>
> In distributed mode, can I set `key.converter` in a connector
> configuration. Some of my connectors use
> `org.apache.kafka.connect.storage.StringConverter` while others would need
> `io.confluent.connect.avro.AvroConverter`.
>
> So I wondered if `key.converter` could be overriden at the connector level.
>
> Thanks.
>