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é <nfou...@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. >
