@karimfarhouti229
Thank you,that helped me and it actually works , good work sir.
@ramachandranelumalai2176
Thanks for all your contents 😊
@chrispure7461
how to read from 2 different queues in the same route ?
@DJSS855
Hi @Saggu,
Do you have any idea how to paas JAAS Config details SASL_SSL
I am trying with below but it is not working (Authentication Error)
Camel:
from("direct:camel")
.log("Input: ${body}")
.process(applicationProcessor)
.log("Output: ${body}")
.choice()
.when(exchange -> CommonUtils.getRestHeader(exchange).equals("BOOKING"))
// .to("{{app.camel-to-booking-service}}")
.to("kafka:my_topic?"
+ "brokers=aql.westeurope.azure.confluent.cloud:9092"
+ "&saslMechanism=PLAIN"
+ "&securityProtocol=SASL_SSL"
+ "&sslProtocol=TLSv1.2"
+ "&sslEnabledProtocols=TLSv1.2"
+ "&sslEndpointAlgorithm=HTTPS"
+ "&saslJaasConfig=org.apache.kafka.common.security.plain.PlainLoginModule required username=\"userID\" password=\"password\";"
+ "&schemaRegistryURL=https://aq71.westeurope.azure.confluent.cloud/"
)
How to pass below properties in camel?
Working Java Code properties:
kafka:
bootstrapserver: ${KAFKA_BOOTSTRAP_SERVERS}
clientId: ${KAFKA_CLIENT_ID}
username: ${KAFKA_USER_NAME}
password: ${KAFKA_PASSWORD}
properties:
saslRequired: true
security.protocol: SASL_SSL
sasl.mechanism: PLAIN
schema.registry.url: ${SCHEMA_REGISTRY_URL}
basic.auth.credentials.source: USER_INFO
schema.registry.basic.auth.user.info: ${SCHEMA_REGISTRY_ACCESS_KEY}
producer:
login-module: org.apache.kafka.common.security.plain.PlainLoginModule required username="${KAFKA_USER_NAME}" password="${KAFKA_PASSWORD}";
@nouramr4143