You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This is because we have sink connector deployed through flux cd pipeline in Kafka Clusters hosted in k8s. So the deployment yaml file treats anything followed by # as acomment. Tried using double quotes but it doesn't work.
Hence I wanted to understand if there are any other way to call the class
The text was updated successfully, but these errors were encountered:
Hi,
Is there a way where we can append #class:
Into the camel configuration.
Currently we need to mention #clas: and then mention the aggregator.
camel.aggregation.size: 1000
camel.aggregation.timeout: 300000
camel.bean.aggregate:#class:org.apache.camel.kafkaconnector.aggregator.StringAggregator
This is because we have sink connector deployed through flux cd pipeline in Kafka Clusters hosted in k8s. So the deployment yaml file treats anything followed by # as acomment. Tried using double quotes but it doesn't work.
Hence I wanted to understand if there are any other way to call the class
The text was updated successfully, but these errors were encountered: