oscerd commented on issue #21:
URL:
https://github.com/apache/camel-kamelets-examples/issues/21#issuecomment-1732608894
Can you go ahead with the PR with the example and use 3.22.0 so we could
use to reproduce? Thanks. The instructions to set up Azure resources too,
are welcome. Thanks!
Il dom 24 set 2023, 17:57 Vedran Kolka ***@***.***> ha
scritto:
> This is my current configuration:
>
> # camel-k:
dependency=mvn:org.apache.camel.kamelets:camel-kamelets-utils:3.20.1.1#
camel-k: dependency=mvn:org.apache.camel.kamelets:azure-identity:0.1# camel-k:
dependency=mvn:com.microsoft.azure:azure-schemaregistry-kafka-avro:1.1.1#
camel-k: dependency=mvn:com.azure:azure-data-schemaregistry-apacheavro:1.1.4#
camel-k: dependency=mvn:com.azure:azure-identity:1.9.0# camle-k:
dependency=mvn:org.apache.camel:camel-kafka:3.20.6
>
> - beans:
> - name: defaultAzureCredential
> type:
"#class:org.apache.camel.kamelets.azure.DefaultAzureCredentialWrapper"
>
> - route:
> id: "kafka-to-log"
> from:
> uri: "kafka:{{kafka.my-topic}}"
> parameters:
> autoOffsetReset: earliest
> brokers: "{{kafka.bootstrapServers}}"
> saslJaasConfig:
'org.apache.kafka.common.security.plain.PlainLoginModule required
username={{kafka.username}} password={{kafka.password}};'
> saslMechanism: PLAIN
> securityProtocol: SASL_SSL
> valueDeserializer:
'com.microsoft.azure.schemaregistry.kafka.avro.KafkaAvroDeserializer'
> groupId: 'my-consumer-group'
> additionalProperties.schema.registry.url:
'{{kafka.schema-registry-url}}'
> additionalProperties.schema.group: avro
> additionalProperties.schema.registry.credential:
'#bean:defaultAzureCredential'
> additionalProperties.specific.avro.value.type:
'#valueAs(java.lang.Class):org.apache.camel.kamelets.eventhubs.models.Order'
> additionalProperties.specific.avro.reader: '#valueAs(boolean):true'
> steps:
> - to:
> uri: "kamelet:log-sink"
> parameters:
> showStreams: true
> showHeaders: true
> multiline: true
>
> And this is the error:
>
> 2023-09-24 17:49:53.389 WARN 18716 --- [sumer[my-topic]]
l.component.kafka.KafkaFetchRecords : Error creating
org.apache.kafka.clients.consumer.KafkaConsumer due to: Failed to construct
kafka consumer
> org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
> at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:825)
~[kafka-clients-3.2.3.jar:?]
> at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:666)
~[kafka-clients-3.2.3.jar:?]
> at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:647)
~[kafka-clients-3.2.3.jar:?]
> at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:627)
~[kafka-clients-3.2.3.jar:?]
> at
org.apache.camel.component.kafka.DefaultKafkaClientFactory.getConsumer(DefaultKafkaClientFactory.java:34)
~[camel-kafka-3.20.1.jar:3.20.1]
> at
org.apache.camel.component.kafka.KafkaFetchRecords.createConsumer(KafkaFetchRecords.java:245)
~[camel-kafka-3.20.1.jar:3.20.1]
> at
org.apache.camel.component.kafka.KafkaFetchRecords.createConsumerTask(KafkaFetchRecords.java:205)
~[camel-kafka-3.20.1.jar:3.20.1]
> at
org.apache.camel.support.task.ForegroundTask.run(ForegroundTask.java:94)
[camel-support-4.0.0.jar:4.0.0]
> at
org.apache.camel.component.kafka.KafkaFetchRecords.run(KafkaFetchRecords.java:127)
[camel-kafka-3.20.1.jar:3.20.1]
> at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?]
> at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
> at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
> at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
> at java.lang.Thread.run(Thread.java:833) [?:?]
> Caused by: java.lang.ClassCastException: class java.lang.String cannot be
cast to class com.azure.core.credential.TokenCredential (java.lang.String is in
module java.base of loader 'bootstrap';
com.azure.core.credential.TokenCredential is in unnamed module of loader
org.apache.camel.main.download.DependencyDownloaderClassLoader @3e8f7922)
> at
com.microsoft.azure.schemaregistry.kafka.avro.AbstractKafkaSerdeConfig.getCredential(AbstractKafkaSerdeConfig.java:66)
~[azure-schemaregistry-kafka-avro-1.1.1.jar:?]
> at
com.microsoft.azure.schemaregistry.kafka.avro.KafkaAvroDeserializerConfig.getCredential(KafkaAvroDeserializerConfig.java:11)
~[azure-schemaregistry-kafka-avro-1.1.1.jar:?]
> at
com.microsoft.azure.schemaregistry.kafka.avro.KafkaAvroDeserializer.configure(KafkaAvroDeserializer.java:55)
~[azure-schemaregistry-kafka-avro-1.1.1.jar:?]
> at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:718)
~[kafka-clients-3.2.3.jar:?]
> ... 13 more
>
> The error looks exactly the same as in the original error of this issue,
> and using camel-kafka-3.22.0 I was able to resolve it, like so:
>
> camel run kafka-log.yaml camel-kafka-3.22.0.jar --properties
application.properties
>
> —
> Reply to this email directly, view it on GitHub
>
<https://github.com/apache/camel-kamelets-examples/issues/21#issuecomment-1732603257>,
> or unsubscribe
>
<https://github.com/notifications/unsubscribe-auth/ABG6XV2BRBKXIXBUVATQ2VTX4BJ5RANCNFSM6AAAAAAYNGZDLM>
> .
> You are receiving this because you were assigned.Message ID:
> ***@***.***>
>
--
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
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
