Hi, Have a look at how we implement the Kafka SCRAM source Kamelet.
https://github.com/apache/camel-kamelets/blob/main/kamelets/kafka-scram-source.kamelet.yaml As far as I see, you need to set also saslMechanism and securityProtocol Cheers. Il giorno ven 1 mar 2024 alle ore 02:20 Chirag <chirag.sangh...@gmail.com> ha scritto: > Hi, > > I am working on a Proof of concept with CloudKarafka (Kafka hosting > provider) and camel. > > I am using camel-jbang 4.4.0 > > Route to write to Kafka@CloudKarafka works fine. > But trying to read from Kafka seems to run into challenge. > > here is my route: > - route: > id: route-09c3 > nodePrefixId: route-229 > from: > id: from-f775 > uri: kafka > parameters: > topic: 4422e1r5-default > brokers: moped.srvs.cloudkafka.com:9094 > saslJaasConfig: >- > org.apache.kafka.common.security.scram.ScramLoginModule > required username='user' > password='password' securityProtocol: SASL_SSL > steps: > - log: > id: log-1987 > message: ${body} > > Here are logs: > he.kafka.common.utils.AppInfoParser : Kafka version: 3.6.1 > he.kafka.common.utils.AppInfoParser : Kafka commitId: 5e3c2b738d253ff5 > he.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1709255355232 > ort.classic.AssignmentAdapterHelper : Using NO-OP resume strategy > l.component.kafka.KafkaFetchRecords : Subscribing 4422e1r5-default-Thread > 0 to topic 4422e1r5-default > afka.clients.consumer.KafkaConsumer : [Consumer > clientId=consumer-12da9c71-2e7d-4726-935f-cf60c349fee3-1, > groupId=12da9c71-2e7d-4726-935f-cf60c349fee3] Subscribed to topic(s): > 4422e1r5-default > .apache.kafka.clients.NetworkClient : [Consumer > clientId=consumer-12da9c71-2e7d-4726-935f-cf60c349fee3-1, > groupId=12da9c71-2e7d-4726-935f-cf60c349fee3] Node -1 disconnected. > .apache.kafka.clients.NetworkClient : [Consumer > clientId=consumer-12da9c71-2e7d-4726-935f-cf60c349fee3-1, > groupId=12da9c71-2e7d-4726-935f-cf60c349fee3] Cancelled in-flight > API_VERSIONS request with correlation id 1 due to node -1 being > disconnected (elapsed time since creation: 401ms, elapsed time since send: > 401ms, request timeout: 30000ms) > .apache.kafka.clients.NetworkClient : [Consumer > clientId=consumer-12da9c71-2e7d-4726-935f-cf60c349fee3-1, > groupId=12da9c71-2e7d-4726-935f-cf60c349fee3] Bootstrap broker > moped.srvs.cloudkafka.com:9094 (id: -1 rack: null) disconnected > .apache.kafka.clients.NetworkClient : [Consumer > clientId=consumer-12da9c71-2e7d-4726-935f-cf60c349fee3-1, > groupId=12da9c71-2e7d-4726-935f-cf60c349fee3] Node -1 disconnected. > .apache.kafka.clients.NetworkClient : [Consumer > clientId=consumer-12da9c71-2e7d-4726-935f-cf60c349fee3-1, > groupId=12da9c71-2e7d-4726-935f-cf60c349fee3] Cancelled in-flight > API_VERSIONS request with correlation id 2 due to node -1 being > disconnected (elapsed time since creation: 216ms, elapsed time since send: > 216ms, request timeout: 30000ms) > .apache.kafka.clients.NetworkClient : [Consumer > clientId=consumer-12da9c71-2e7d-4726-935f-cf60c349fee3-1, > groupId=12da9c71-2e7d-4726-935f-cf60c349fee3] Bootstrap broker > moped.srvs.cloudkafka.com:9094 (id: -1 rack: null) disconnected > .apache.kafka.clients.NetworkClient : [Consumer > clientId=consumer-12da9c71-2e7d-4726-935f-cf60c349fee3-1, > groupId=12da9c71-2e7d-4726-935f-cf60c349fee3] Node -1 disconnected. > .apache.kafka.clients.NetworkClient : [Consumer > clientId=consumer-12da9c71-2e7d-4726-935f-cf60c349fee3-1, > groupId=12da9c71-2e7d-4726-935f-cf60c349fee3] Cancelled in-flight > API_VERSIONS request with correlation id 3 due to node -1 being > disconnected (elapsed time since creation: 313ms, elapsed time since send: > 313ms, request timeout: 30000ms) > > Does this require any other type of param to read successfully? > > ચિરાગ/चिराग/Chirag > ------------------------------------------ > Sent from My Gmail Account >
