vedran-kolka-syntio opened a new issue, #1492:
URL: https://github.com/apache/camel-kamelets/issues/1492
Hi! It would be great if `additionalProperties` in the kafka component would
support boolean values when writing in YAML DSL.
Right now, the following route:
```yaml
- route:
id: "kafka-to-somewhere"
from:
uri: "kafka:{{kafka.my-topic}}"
parameters:
additionalProperties.specific.avro.reader: true
....
```
fails with the following exception:
```
Caused by: java.lang.ClassCastException: class java.lang.String cannot be
cast to class java.lang.Boolean (java.lang.String and java.lang.Boolean are in
module java.base of loader 'bootstrap')
```
Stacktrace:
```
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.6-fix.jar:3.20.5-SNAPSHOT]
at
org.apache.camel.component.kafka.KafkaFetchRecords.createConsumer(KafkaFetchRecords.java:245)
~[camel-kafka-3.20.6-fix.jar:3.20.5-SNAPSHOT]
at
org.apache.camel.component.kafka.KafkaFetchRecords.createConsumerTask(KafkaFetchRecords.java:205)
~[camel-kafka-3.20.6-fix.jar:3.20.5-SNAPSHOT]
at
org.apache.camel.support.task.ForegroundTask.run(ForegroundTask.java:93)
~[camel-support-3.20.5-SNAPSHOT.jar:3.20.5-SNAPSHOT]
at
org.apache.camel.component.kafka.KafkaFetchRecords.run(KafkaFetchRecords.java:127)
~[camel-kafka-3.20.6-fix.jar:3.20.5-SNAPSHOT]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
~[?:?]
at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.lang.ClassCastException: class java.lang.String cannot be
cast to class java.lang.Boolean (java.lang.String and java.lang.Boolean are in
module java.base of loader 'bootstrap')
at
com.microsoft.azure.schemaregistry.kafka.avro.KafkaAvroDeserializerConfig.getAvroSpecificReader(KafkaAvroDeserializerConfig.java:32)
~[azure-schemaregistry-kafka-avro-1.1.1.jar:?]
at
com.microsoft.azure.schemaregistry.kafka.avro.KafkaAvroDeserializer.configure(KafkaAvroDeserializer.java:57)
~[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
```
--
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
