olivierdeckers opened a new issue, #1542:
URL: https://github.com/apache/camel-kafka-connector/issues/1542
Hello! I am trying to use the CamelKafkasslsinkSinkConnector to move a
binary payload from one kafka cluster to another. Messages are being produced
on the target cluster, but they payload is not completely identical. I
discovered this is because the connectors' kafka producer is using
StringSerializer as value.serializer. It logs: `value.serializer = class
org.apache.kafka.common.serialization.StringSerializer
(org.apache.kafka.clients.producer.ProducerConfig:376)`
I configured the connector like this:
```
{
"camel.idempotency.enabled": "false",
"camel.kamelet.kafka-ssl-sink.bootstrapServers":
"localhost:9094",
"camel.kamelet.kafka-ssl-sink.sslKeyPassword": "...",
"camel.kamelet.kafka-ssl-sink.sslKeystoreLocation": "...",
"camel.kamelet.kafka-ssl-sink.sslKeystorePassword": "...",
"camel.kamelet.kafka-ssl-sink.sslTruststoreLocation": "...",
"camel.kamelet.kafka-ssl-sink.topic": "target-topic",
"camel.map.headers": "true",
"camel.map.properties": "true",
"connector.class":
"org.apache.camel.kafkaconnector.kafkasslsink.CamelKafkasslsinkSinkConnector",
"errors.deadletterqueue.context.headers.enable": "false",
"errors.log.enable": "true",
"errors.log.include.messages": "false",
"header.converter":
"org.apache.kafka.connect.converters.ByteArrayConverter",
"key.converter":
"org.apache.kafka.connect.converters.ByteArrayConverter",
"name": "camel-kafka-ssl-sink-connector-test",
"topics": "source-topic",
"value.converter":
"org.apache.kafka.connect.converters.ByteArrayConverter"
}
```
I cannot find in the documentation how to configure the value.serializer
config used for creating the kafka producer. I also tried adding a couple of
things to the connector config, like: producer.override.value.serializer,
producer.value.serializer, value.serializer, ...
but none of them seem to have any effect.
Is it possible to configure this? Shouldn't the producer default to
ByteArrayConverter to make sure the connector can handle both text and binary
payloads?
--
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-unsubscr...@camel.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
