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."

Reply via email to