Hi,
Is there any way to configure custom Kafka producer/consumer properties on the
Camel Kafka component/endpoint (without "breaking in")?
I specifically want to configure the Confluent Kafka property with key
'value.subject.name.strategy':
https://docs.confluent.io/current/schema-registry/serializer-formatter.html
Other Camel components (i.e Camel ActiveMQ; destination.consumer) are made
extensible by providing users a way to set "additional properties". Why does
not Camel Kafka provide that? Until schemaRegistryURL was added as a
configurable property, we had to make our own Camel Kafka Component to make it
work ("breaking in"). There should definitely be a way to set additional/custom
properties on Kafka producers/consumers.
Just have a look at the Camel Kafka documentation and do a text search for
Confluent: https://camel.apache.org/components/latest/kafka-component.html ;-)
Having "native" support for schemas on Kafka records is definitely a good idea,
and I am pretty sure Apache Kafka will move in that direction at some point....
Erik
"This email with attachments is solely for the use of the individual or entity
to which it is addressed. It may contain confidential or privileged
information. If you are not the addressee, please notify the sender and delete
this message and all attachments from your files."