[GitHub] [camel-kafka-connector] jakubmalek commented on issue #1542: CamelKafkasslsinkSinkConnector not handling binary payloads well

["jakubmalek (via GitHub)" <gi...@apache.org>]

jakubmalek commented on issue #1542:
URL: https://github.com/apache/camel-kafka-connector/issues/1542#issuecomment-1657830394

   Hi @olivierdeckers, the `producer.override` setting are only applicable to the Source connectors, that produce data into the topics. In here you're using Sink connector, where converters are used to deserialize the `ConsumerRecord` into `SinkRecord` which can be later transformed before it's passed to the plugin. 
   
   If you need to configure the producer used internally by the plugin, you need to look at configuration properties for  [camel-kafka](https://github.com/apache/camel/tree/main/components/camel-kafka) component.
   You can find list of component properties in [here](https://github.com/apache/camel/blob/main/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json#L24) for example.
   The properties for the component can be specified with `camel.component.$componentName` prefix in your case `camel.component.kafka`.
   As I see by default the `camel.component.kafka.valueSerializer` is set to `org.apache.kafka.common.serialization.StringSerializer` which might explain the problem.
   
   You may also consider using MirrorMaker2 connector, available by default in Kafka. Although it does little bit more than simply producing the data, as it also synchronizes Kafka topic partitions.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org