vedran-kolka-syntio commented on issue #21:
URL:
https://github.com/apache/camel-kamelets-examples/issues/21#issuecomment-1734251224
Yes, I have made the JAR for the example, not for the company internally. It
also contains `Order`. I will rename it.
Running what you suggested with camel-kafka-4.0.0 gives the following error
upon KafkaConsumer construction:
```bash
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:?]
...
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)
```
Using camel-kafka-3.22.0 it fails earlier:
```bash
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to
resolve endpoint:
kafka://my-topic?additionalProperties.schema.group=avro&additionalProperties.schema.registry.credential=%23bean%3AdefaultAzureCredential&additionalProperties.schema.registry.url=https%3A%2F%2Flabscamel-eventhubs-dev.servicebus.windows.net&additionalProperties.specific.avro.reader=%23valueAs%28boolean%29%3Atrue&additionalProperties.specific.avro.value.type=%23type%3Acom.acme.example.eventhubs.models.Order&autoOffsetReset=earliest&brokers=labscamel-eventhubs-dev.servicebus.windows.net%3A9093&groupId=my-consumer-group&saslJaasConfig=xxxxxx&saslMechanism=PLAIN&securityProtocol=SASL_SSL&valueDeserializer=com.microsoft.azure.schemaregistry.kafka.avro.KafkaAvroDeserializer
due to: Error binding property
(specific.avro.value.type=#type:com.acme.example.eventhubs.models.Order) with
name: specific.avro.value.type on bean:
{schema.registry.url=https://labscamel-eventhubs-dev.servicebus.windows.net,
schema
.group=avro,
schema.registry.credential=com.acme.example.azure.DefaultAzureCredentialWrapper@322204dc,
specific.avro.reader=true} with value:
#type:com.acme.example.eventhubs.models.Order
at
org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:856)
at
org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:758)
at
org.apache.camel.support.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:60)
at
org.apache.camel.reifier.AbstractReifier.resolveEndpoint(AbstractReifier.java:195)
at
org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:96)
at
org.apache.camel.reifier.RouteReifier.createRoute(RouteReifier.java:76)
... 26 more
Caused by: org.apache.camel.PropertyBindingException: Error binding property
(specific.avro.value.type=#type:com.acme.example.eventhubs.models.Order) with
name: specific.avro.value.type on bean:
{schema.registry.url=https://labscamel-eventhubs-dev.servicebus.windows.net,
schema.group=avro,
schema.registry.credential=com.acme.example.azure.DefaultAzureCredentialWrapper@322204dc,
specific.avro.reader=true} with value:
#type:com.acme.example.eventhubs.models.Order
at
org.apache.camel.support.PropertyBindingSupport.doSetPropertyValue(PropertyBindingSupport.java:548)
at
org.apache.camel.support.PropertyBindingSupport.doBuildPropertyOgnlPath(PropertyBindingSupport.java:420)
at
org.apache.camel.support.PropertyBindingSupport.doBindProperties(PropertyBindingSupport.java:297)
at
org.apache.camel.support.PropertyBindingSupport$Builder.bind(PropertyBindingSupport.java:1906)
at
org.apache.camel.support.PropertyBindingSupport.bindProperties(PropertyBindingSupport.java:132)
at
org.apache.camel.component.kafka.KafkaComponent.createEndpoint(KafkaComponent.java:87)
at
org.apache.camel.component.kafka.KafkaComponent.createEndpoint(KafkaComponent.java:34)
at
org.apache.camel.support.DefaultComponent.createEndpoint(DefaultComponent.java:170)
at
org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:822)
... 31 more
Caused by: java.lang.IllegalStateException: Cannot select single type:
com.acme.example.eventhubs.models.Order as there are no beans in the registry
with this type
at
org.apache.camel.support.PropertyBindingSupport.resolveBean(PropertyBindingSupport.java:1597)
at
org.apache.camel.support.PropertyBindingSupport.resolveValue(PropertyBindingSupport.java:902)
at
org.apache.camel.support.PropertyBindingSupport.doSetPropertyValue(PropertyBindingSupport.java:538)
... 39 more
```
After defining an Order as a bean:
```yaml
- beans:
- name: order
type: "#class:com.acme.example.eventhubs.models.Order"
```
The following error occurs, upon deserializing the message (still using
camel-kafka-3.22.0):
```bash
org.apache.kafka.common.errors.RecordDeserializationException: Error
deserializing key/value for partition my-topic-0 at offset 11. If needed,
please seek past the record to continue consumption.
at
org.apache.kafka.clients.consumer.internals.Fetcher.parseRecord(Fetcher.java:1435)
~[kafka-clients-3.2.3.jar:?]
...
Caused by: java.lang.ClassCastException: class
com.acme.example.eventhubs.models.Order cannot be cast to class java.lang.Class
(com.acme.example.eventhubs.models.Order is in unnamed module of loader
org.apache.camel.main.download.DependencyDownloaderClassLoader @3e8f7922;
java.lang.Class is in module java.base of loader 'bootstrap')
```
Could you provide a link to any documentation describing the operations
invoked with `#` (`#valueAs`, `#bean`, `#type`, `#class`...) ?
I am having trouble using these and cannot seem to find the docs.
--
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
