L040639 opened a new issue, #1697: URL: https://github.com/apache/camel-kafka-connector/issues/1697
i am trying to deploy a kafka connector which will authenticate to the oauth protected kafka cluster, so using camel sqs sink connector but i am getting below error , does camel sink connector not supporting oauth2.0 scope Caused by: javax.security.auth.login.LoginException: io.strimzi.kafka.oauth.common.HttpException: POST request to https://login.microsoftonline.com/18a59a81-eea8-4c30-948a-d8824cdc2580/oauth2/v2.0/token failed with status 400: {"error":"invalid_request","error_description":"AADSTS90014: The required field 'scope' is missing from the credential. Ensure that you have all the necessary parameters for the login request. Trace ID: afeb7f73-4348-4f19-a398-ac0df5bb2100 Correlation ID: 89c056d2-d633-4813-b9f7-b5ac2b342fac Timestamp: 2025-01-26 09:11:56Z","error_codes":[90014],"timestamp":"2025-01-26 09:11:56Z","trace_id":"afeb7f73-4348-4f19-a398-ac0df5bb2100","correlation_id":"89c056d2-d633-4813-b9f7-b5ac2b342fac","error_uri":"https://login.microsoftonline.com/error?code=90014"} ```yaml apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnect metadata: name: my-connect-cluster annotations: strimzi.io/use-connector-resources: "true" spec: version: 3.7.0 replicas: 1 image: xxxxxx bootstrapServers: xxxxx tls: trustedCertificates: - secretName: lk-ca-root-bundle certificate: ca.crt logging: type: inline loggers: log4j.rootLogger: INFO readinessProbe: # (13) initialDelaySeconds: 15 timeoutSeconds: 5 livenessProbe: initialDelaySeconds: 15 timeoutSeconds: 5 config: group.id: xxxxxx offset.storage.topic: connectoffsets config.storage.topic: connectconfigs status.storage.topic: connectstatus # key.converter: org.apache.kafka.connect.json.JsonConverter # value.converter: org.apache.kafka.connect.json.JsonConverter # key.converter.schemas.enable: true # value.converter.schemas.enable: true config.storage.replication.factor: 3 offset.storage.replication.factor: 3 status.storage.replication.factor: 3 template: pod: metadata: annotations: eks.amazonaws.com/role-arn: xxxxxx imagePullSecrets: - name: kafka-artifactory terminationGracePeriodSeconds: 120 serviceAccount: metadata: annotations: eks.amazonaws.com/role-arn: xxxxxxxx authentication: type: oauth clientId: xxxxxxx clientSecret: key: secret secretName: kafka-clientsecret scope: xxxxxxx tokenEndpointUri: 'https://login.microsoftonline.com/xxxxxxxx ``` ```yaml apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnector metadata: name: my-source-connector labels: strimzi.io/cluster: my-connect-cluster spec: class: org.apache.camel.kafkaconnector.awssqssink.CamelAwssqssinkSinkConnector config: topics: "xxxxxx" camel.kamelet.aws-sqs-sink.queueNameOrArn: xxxxxxx camel.kamelet.aws-sqs-sink.useSessionCredentials: "true" camel.kamelet.aws-sqs-sink.region: "us-east-2" ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
