vedran-kolka-syntio commented on issue #21:
URL:
https://github.com/apache/camel-kamelets-examples/issues/21#issuecomment-1732603257
This is my current configuration:
```yaml
# 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:
```bash
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:
```bash
camel run kafka-log.yaml camel-kafka-3.22.0.jar --properties
application.properties
```
--
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
