Re: could not display ${out.body} at Log for external soap service provider

2018-12-05 Thread Claus Ibsen
Hi

Just use ${body}

Also mind about logging streaming data, you may only be able to read
it once. See this FAQ
http://camel.apache.org/why-is-my-message-body-empty.html
On Wed, Nov 21, 2018 at 1:49 PM Wang Yan  wrote:
>
> i already got reply from to uri which is mock soap service (external soap
> provider)
> but why i could not see it in log with ${out.body}
> i think soap is InOut exchangepattern, it should have out.body always
> my code example looks like below
>
> Any hints are more than welcome!
>
>  uri="cxf://http://{{soap.ip}}:{{soap.port}}/{{soap.service}}?dataFormat=MESSAGEwsdlURL=wsdl%2Fmyservice.wsdl;
> />
> 
>  loggingLevel="INFO" />
> 
>  loggingLevel="INFO" />



-- 
Claus Ibsen
-
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2


Re: Re: readLockLoggingLevel File Component

2018-12-05 Thread Claus Ibsen
Hi

Thanks for spotting this. I am correcting the docs.
On Thu, Nov 29, 2018 at 9:03 AM  wrote:
>
> Yes Zoran,
>
> sometimes I have a great enlightenment;)
> But even small things can slow down your work (if you wonder, why a file
> is not consumed, cause this is only logged at debug)...
>
> Björn
>
>
>
>
> Von:Claus Ibsen 
> An: users@camel.apache.org
> Datum:  28.11.2018 18:29
> Betreff:Re: readLockLoggingLevel File Component
>
>
>
> Hi
>
> Yeah you are welcome to provide a fix via a github PR
> https://github.com/apache/camel/blob/master/CONTRIBUTING.md
>
> If you are a bit lazy you can even just do the PR by editing the
> source file from the github web ui directly
> On Wed, Nov 28, 2018 at 2:34 PM Zoran Regvart  wrote:
> >
> > Hi Björn,
> > sounds like a great contribution, we love those :)
> >
> > zoran
> > On Wed, Nov 28, 2018 at 1:19 PM  wrote:
> > >
> > > Hi,
> > >
> > > one little thing...
> > > I have noticed that in the javadocs, documentations,... for the the
> > > property readLockLoggingLevel in the File Component, respectively in
> the
> > > class FileChangedExclusiveReadLockStrategy the default is described as
> > > 'WARN'. But in the implementation it is 'DEBUG'. It could be helpful
> to
> > > adjust this...
> > >
> > > Best regards
> > > Björn
> > >
> > >
> > > Diese E-Mail könnte vertrauliche und / oder rechtlich geschützte
> Informationen enthalten. Wenn Sie nicht der richtige Adressat sind oder
> diese E-Mail irrtümlich erhalten haben, informieren Sie bitte sofort den
> Absender und vernichten Sie diese Mail. Das unerlaubte Kopieren sowie die
> unbefugte Weitergabe dieser Mail sind nicht gestattet.
> > >
> > > This e-mail may contain confidential and / or privileged information.
> If you are not the intended recipient (or have received this e-mail in
> error) please notify the sender immediately and destroy this e-mail. Any
> unauthorised copying, disclosure or distribution of the material in this
> e-mail is strictly forbidden.
> >
> >
> >
> > --
> > Zoran Regvart
>
>
>
> --
> Claus Ibsen
> -
> http://davsclaus.com @davsclaus
> Camel in Action 2: https://www.manning.com/ibsen2
>
>
>
>
> Diese E-Mail könnte vertrauliche und / oder rechtlich geschützte 
> Informationen enthalten. Wenn Sie nicht der richtige Adressat sind oder diese 
> E-Mail irrtümlich erhalten haben, informieren Sie bitte sofort den Absender 
> und vernichten Sie diese Mail. Das unerlaubte Kopieren sowie die unbefugte 
> Weitergabe dieser Mail sind nicht gestattet.
>
> This e-mail may contain confidential and / or privileged information. If you 
> are not the intended recipient (or have received this e-mail in error) please 
> notify the sender immediately and destroy this e-mail. Any unauthorised 
> copying, disclosure or distribution of the material in this e-mail is 
> strictly forbidden.



-- 
Claus Ibsen
-
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2


Fwd: configure SSL for CAMEL LDAP

2018-12-05 Thread Wang Yan
it does not work got exception as below

#camel xmlroute scan
camel.springboot.xmlRoutes: on
camel.springboot.xmlRoutes: file:camel/*.xml


Caused by: java.lang.IllegalStateException: duplicate key:
camel.springboot.xmlRoutes


-- Forwarded message -
From: Wang Yan 
Date: Tue, Nov 27, 2018 at 10:40 AM
Subject: configure SSL for CAMEL LDAP
To: 



Currently I am reading the document http://camel.apache.org/ldap.html

and try to configure SSL for LDAP , I did not find how or where the bean
ldapserver refers to the bean customSocketFactory.

Any suggestions or hints are more than weclome!



http://www.osgi.org/xmlns/blueprint/v1.0.0;
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
   xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0
https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
 http://camel.apache.org/schema/blueprint
http://camel.apache.org/schema/blueprint/camel-blueprint.xsd;>


http://camel.apache.org/schema/blueprint;
  id="sslContextParameters">
























Re: large xml files using groovy

2018-12-05 Thread Claus Ibsen
Hi

How is reading an XML file via Java code related to a SOAP endpoint?

Yeah you can read xml files in a streaming mode via a reader. Mind
that it depends what you need to do with the XML data whether you need
to read the entire XML into memory and build a DOM tree etc.
20mb is not so large anymore, so reading into memory should be fine imho.

And yeah for streaming you may need that, but it depends what you do,
and what Camel need to do.


On Mon, Nov 26, 2018 at 10:19 AM Raymond de Hond
 wrote:
>
> Hi,
>
> I created a camel route using a soap endpoint (contract first) using format
> PAYLOAD.
>
> My question is, what's the best approach to read large xml messages (up to
> 20mb)  using groovy xmlSlurper? This slurper accepts a java.io.Reader as
> input. Is it possible to do something like:
>
>
> def xml = exchange.getIn().getBody(java.io.Reader);
>
>
> And should I enable streamCache = true on my route?
>
>
> Regards,
>
>
> Raymond



-- 
Claus Ibsen
-
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2


Re: Kafka component Spring boot auto configuration

2018-12-05 Thread Claus Ibsen
Hi

What version of Camel, Kafka and SB are you using?

On Tue, Dec 4, 2018 at 8:59 AM Yoshimo  wrote:
>
> Hello Camel users,
>
> I am trying to auto configure the Kafka component using spring boot, but the 
> configuration is not working. More specifically I am following this page:
>
> https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc
>
> and I am trying to set this configuration in my yaml file:
> camel.component.kafka.configuration.value-deserializer
>
> However the default deserializer is used when I consume from the Kafka topic. 
> If I specify the deserializer in the Kafka route then it works as expected. 
> Also I have defined the configuration camel.springboot.name in my yaml file 
> and I can see that it is picked up normally. Are there any configurations 
> that enable this functionality and I am missing?
>
> Thank you,
> Yiannis



-- 
Claus Ibsen
-
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2


Fwd: using springdsl instead of javadsl with file path

2018-12-05 Thread Wang Yan
it does not work got exception as below

#camel xmlroute scan
camel.springboot.xmlRoutes: on
camel.springboot.xmlRoutes: file:camel/*.xml


Caused by: java.lang.IllegalStateException: duplicate key:
camel.springboot.xmlRoutes

-- Forwarded message -
From: Wang Yan 
Date: Tue, Nov 20, 2018 at 10:28 AM
Subject: using springdsl instead of javadsl with file path
To: 




using springdsl instead of javadsl, below is the example from camel website,

is it possible to use file instead of classpath for configuration? for example

camel.springboot.xmlRoutes = file:/com/foo/routes/*.xml

any suggestions and hints are more than welcome!

// turn off
camel.springboot.xmlRoutes = false
// scan in the com/foo/routes classpath
camel.springboot.xmlRoutes = classpath:com/foo/routes/*.xml

The XML files should be Camel XML routes (not CamelContext) such as

   http://camel.apache.org/schema/spring;>



ref:myBean






Re: using springdsl instead of javadsl with file path

2018-12-05 Thread Claus Ibsen
Hi

Maybe try separating mutliple paths with comma and only have 1 key
On Wed, Dec 5, 2018 at 11:11 AM Wang Yan  wrote:
>
> it does not work got exception as below
>
> #camel xmlroute scan
> camel.springboot.xmlRoutes: on
> camel.springboot.xmlRoutes: file:camel/*.xml
>
>
> Caused by: java.lang.IllegalStateException: duplicate key:
> camel.springboot.xmlRoutes
>
> -- Forwarded message -
> From: Wang Yan 
> Date: Tue, Nov 20, 2018 at 10:28 AM
> Subject: using springdsl instead of javadsl with file path
> To: 
>
>
>
>
> using springdsl instead of javadsl, below is the example from camel website,
>
> is it possible to use file instead of classpath for configuration? for example
>
> camel.springboot.xmlRoutes = file:/com/foo/routes/*.xml
>
> any suggestions and hints are more than welcome!
>
> // turn off
> camel.springboot.xmlRoutes = false
> // scan in the com/foo/routes classpath
> camel.springboot.xmlRoutes = classpath:com/foo/routes/*.xml
>
> The XML files should be Camel XML routes (not CamelContext) such as
>
>http://camel.apache.org/schema/spring;>
> 
> 
> 
> ref:myBean
> 
> 
> 
> 



-- 
Claus Ibsen
-
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2


Re: Component options

2018-12-05 Thread Claus Ibsen
No you can get the options of a component via its instance type, eg
HttpComponent has getter/setter for all its options.

To set default values on components you do as in (2) or if you use
spring-boot you can set them via SB auto configuration etc.

On Fri, Nov 23, 2018 at 9:24 PM ski n  wrote:
>
> I have two questions regarding Component options:
>
> 1) Is it possible to get all options as a Map
>
> From the context it's possible to get component:
>
> context.getComponent("componentName");
>
> It also possible to get the Component documentation like
>
> context.getComponentDocumentation("componentName");
>
> or in later version from the catalog:
> catalog.componentHtmlDoc(componentType);
>
> or use context.explainComponentJson(componentName, includeAllOptions)
>
> However this returns documents  (HTML/JSON). I would like to have a
> Map return like getting the globaloptions:
>
> context.getGlobalOptions()
>
> For example:
>
> context.getComponentOptions("componentName");
>
>
> 2) Is it possible to set another default?
>
> I like to change some of the defaults for components. I know I can do
> something like this:
>
> HttpComponent http = context.getComponent("http4", HttpComponent.class);
> http.setConnectionTimeToLive(5000);
>
> Is there also a more direct way. For example:
>
> context.setComponentOption("componentName","option","value");
>
> Raymond



-- 
Claus Ibsen
-
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2


Re: Apache Camel Question

2018-12-05 Thread Claus Ibsen
Hi

No removal is not supported. The file component is primary designed
for exchange data via files.
Not really for monitoring directory folders. Also the original Java
File API didnt support this either.

You can use the newer Java File API for this.

And its not on the roadmap to add this feature as it would require
significant changes to use the newer
Java file API which also can have slightly different way of operating
depending on the underlying File system.

And its not a common use-case (yet) to react on files being deleted.


On Wed, Nov 21, 2018 at 2:39 PM Piotr Niewinski
 wrote:
>
> Hello Apache Camel Team,
>
> We are currently working on a project and we have been using Apache Camel
> for one year now. Great product.
>
> Recently we wanted to use it for monitoring file changes when user
> creates/modifes/removes files. First two options work perfectly fine, but
> detecting manually removed files/directories seems to be not supported by
> Camel.
>
> The questions is: is it possible to somehow detect manually removed files,
> ofc with Apache Camel File component.
>
> PS. What do you think about adding such feature?
>
> Created stackoverflow question:
> https://stackoverflow.com/questions/53374643/apache-camel-to-detect-manually-removed-files
>
>
> Thanks & Best regards,
> P. Niewiński
>
>
> Pozdrawiam
> P. Niewiński



-- 
Claus Ibsen
-
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2


Re: Kafka component Spring boot auto configuration

2018-12-05 Thread Yoshimo
Here is what I add to my yaml file:

camel.component.kafka.configuration.value-deserializer: 
com.openbet.platform.pricepublisher.serde.SportsEventDeserializer

and here is my route:

from("kafka:prices?brokers={{kafka.servers}}")
.convertBodyTo(DBModel.class)
..

With this setup when I start the app I can see in the logs the Kafka 
configuration in the consumer:

value.deserializer = class 
org.apache.kafka.common.serialization.StringDeserializer

and I get exceptions while deserializing. However if I remove the config from 
the yaml file and update my route to be:

kafka:prices?brokers={{kafka.servers}}=com.openbet.platform.pricepublisher.serde.SportsEventDeserializer

then I see the following in the Kafka consumer config:

value.deserializer = class 
com.openbet.platform.pricepublisher.serde.SportsEventDeserializer

and the app works as expected. Just for reference the rest of my yaml file is:

kafka:
  sportsTopic: sports
  pricesTopic: prices
  servers: localhost:25445
  streams:
"[application.id]": price-publisher
"[bootstrap.servers]": ${kafka.servers}
"[default.key.serde]": 
com.openbet.platform.pricepublisher.serde.ActivityKeySerDe
"[default.value.serde]": 
com.openbet.platform.pricepublisher.serde.ActivityValueSerDe

Thank you,
Yiannis

‐‐‐ Original Message ‐‐‐
On Wednesday, 5 December 2018 13:30, Claus Ibsen  wrote:

> Hi
>
> Can you post your yaml configuration of how you try to configure this
> kafka value deserializer
> On Wed, Dec 5, 2018 at 11:36 AM Yoshimo yosh...@protonmail.com wrote:
>
> > Hello Claus,
> > thank you for looking into this.
> > Camel: 2.23.0
> > Kafka: 2.0.0
> > SB: 2.1.0.RELEASE
> > I am also attaching my pom if you want to have a look.
> > Thank you,
> > Yiannis
> > ‐‐‐ Original Message ‐‐‐
> > On Wednesday, 5 December 2018 12:15, Claus Ibsen claus.ib...@gmail.com 
> > wrote:
> >
> > > Hi
> > > What version of Camel, Kafka and SB are you using?
> > > On Tue, Dec 4, 2018 at 8:59 AM Yoshimo yosh...@protonmail.com.invalid 
> > > wrote:
> > >
> > > > Hello Camel users,
> > > > I am trying to auto configure the Kafka component using spring boot, 
> > > > but the configuration is not working. More specifically I am following 
> > > > this page:
> > > > https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc
> > > > and I am trying to set this configuration in my yaml file:
> > > > camel.component.kafka.configuration.value-deserializer
> > > > However the default deserializer is used when I consume from the Kafka 
> > > > topic. If I specify the deserializer in the Kafka route then it works 
> > > > as expected. Also I have defined the configuration 
> > > > camel.springboot.name in my yaml file and I can see that it is picked 
> > > > up normally. Are there any configurations that enable this 
> > > > functionality and I am missing?
> > > > Thank you,
> > > > Yiannis
> > >
> > > --
> > > Claus Ibsen
> > >
> > > http://davsclaus.com @davsclaus
> > > Camel in Action 2: https://www.manning.com/ibsen2
>
> --
>
> Claus Ibsen
>
> 
>
> http://davsclaus.com @davsclaus
> Camel in Action 2: https://www.manning.com/ibsen2




Fwd: using springdsl instead of javadsl with file path

2018-12-05 Thread Wang Yan
it seems  only support keyword classpath but not file

 camel.springboot.xmlRoutes: classpath:camel/*.xml



-- Forwarded message -
From: Wang Yan 
Date: Wed, Dec 5, 2018 at 11:11 AM
Subject: Fwd: using springdsl instead of javadsl with file path
To: 



it does not work got exception as below

#camel xmlroute scan
camel.springboot.xmlRoutes: on
camel.springboot.xmlRoutes: file:camel/*.xml


Caused by: java.lang.IllegalStateException: duplicate key:
camel.springboot.xmlRoutes

-- Forwarded message -
From: Wang Yan 
Date: Tue, Nov 20, 2018 at 10:28 AM
Subject: using springdsl instead of javadsl with file path
To: 




using springdsl instead of javadsl, below is the example from camel website,

is it possible to use file instead of classpath for configuration? for example

camel.springboot.xmlRoutes = file:/com/foo/routes/*.xml

any suggestions and hints are more than welcome!

// turn off
camel.springboot.xmlRoutes = false
// scan in the com/foo/routes classpath
camel.springboot.xmlRoutes = classpath:com/foo/routes/*.xml

The XML files should be Camel XML routes (not CamelContext) such as

   http://camel.apache.org/schema/spring;>



ref:myBean






Re: Kafka component Spring boot auto configuration

2018-12-05 Thread Yoshimo
Hello Claus,

thank you for looking into this.
Camel: 2.23.0
Kafka: 2.0.0
SB: 2.1.0.RELEASE

I am also attaching my pom if you want to have a look.

Thank you,
Yiannis


‐‐‐ Original Message ‐‐‐
On Wednesday, 5 December 2018 12:15, Claus Ibsen  wrote:

> Hi
>
> What version of Camel, Kafka and SB are you using?
>
> On Tue, Dec 4, 2018 at 8:59 AM Yoshimo yosh...@protonmail.com.invalid wrote:
>
> > Hello Camel users,
> > I am trying to auto configure the Kafka component using spring boot, but 
> > the configuration is not working. More specifically I am following this 
> > page:
> > https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc
> > and I am trying to set this configuration in my yaml file:
> > camel.component.kafka.configuration.value-deserializer
> > However the default deserializer is used when I consume from the Kafka 
> > topic. If I specify the deserializer in the Kafka route then it works as 
> > expected. Also I have defined the configuration camel.springboot.name in my 
> > yaml file and I can see that it is picked up normally. Are there any 
> > configurations that enable this functionality and I am missing?
> > Thank you,
> > Yiannis
>
> --
>
> Claus Ibsen
>
> 
>
> http://davsclaus.com @davsclaus
> Camel in Action 2: https://www.manning.com/ibsen2




Re: Kafka component Spring boot auto configuration

2018-12-05 Thread Claus Ibsen
On Wed, Dec 5, 2018 at 12:56 PM Yoshimo  wrote:
>
> Here is what I add to my yaml file:
>
> camel.component.kafka.configuration.value-deserializer: 
> com.openbet.platform.pricepublisher.serde.SportsEventDeserializer
>
> and here is my route:
>
> from("kafka:prices?brokers={{kafka.servers}}")
> .convertBodyTo(DBModel.class)
> ..
>
> With this setup when I start the app I can see in the logs the Kafka 
> configuration in the consumer:
>
> value.deserializer = class 
> org.apache.kafka.common.serialization.StringDeserializer
>

Try with

value.deserializer = org.apache.kafka.common.serialization.StringDeserializer



> and I get exceptions while deserializing. However if I remove the config from 
> the yaml file and update my route to be:
>
> kafka:prices?brokers={{kafka.servers}}=com.openbet.platform.pricepublisher.serde.SportsEventDeserializer
>
> then I see the following in the Kafka consumer config:
>
> value.deserializer = class 
> com.openbet.platform.pricepublisher.serde.SportsEventDeserializer
>
> and the app works as expected. Just for reference the rest of my yaml file is:
>
> kafka:
>   sportsTopic: sports
>   pricesTopic: prices
>   servers: localhost:25445
>   streams:
> "[application.id]": price-publisher
> "[bootstrap.servers]": ${kafka.servers}
> "[default.key.serde]": 
> com.openbet.platform.pricepublisher.serde.ActivityKeySerDe
> "[default.value.serde]": 
> com.openbet.platform.pricepublisher.serde.ActivityValueSerDe
>
> Thank you,
> Yiannis
>
> ‐‐‐ Original Message ‐‐‐
> On Wednesday, 5 December 2018 13:30, Claus Ibsen  
> wrote:
>
> > Hi
> >
> > Can you post your yaml configuration of how you try to configure this
> > kafka value deserializer
> > On Wed, Dec 5, 2018 at 11:36 AM Yoshimo yosh...@protonmail.com wrote:
> >
> > > Hello Claus,
> > > thank you for looking into this.
> > > Camel: 2.23.0
> > > Kafka: 2.0.0
> > > SB: 2.1.0.RELEASE
> > > I am also attaching my pom if you want to have a look.
> > > Thank you,
> > > Yiannis
> > > ‐‐‐ Original Message ‐‐‐
> > > On Wednesday, 5 December 2018 12:15, Claus Ibsen claus.ib...@gmail.com 
> > > wrote:
> > >
> > > > Hi
> > > > What version of Camel, Kafka and SB are you using?
> > > > On Tue, Dec 4, 2018 at 8:59 AM Yoshimo yosh...@protonmail.com.invalid 
> > > > wrote:
> > > >
> > > > > Hello Camel users,
> > > > > I am trying to auto configure the Kafka component using spring boot, 
> > > > > but the configuration is not working. More specifically I am 
> > > > > following this page:
> > > > > https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc
> > > > > and I am trying to set this configuration in my yaml file:
> > > > > camel.component.kafka.configuration.value-deserializer
> > > > > However the default deserializer is used when I consume from the 
> > > > > Kafka topic. If I specify the deserializer in the Kafka route then it 
> > > > > works as expected. Also I have defined the configuration 
> > > > > camel.springboot.name in my yaml file and I can see that it is picked 
> > > > > up normally. Are there any configurations that enable this 
> > > > > functionality and I am missing?
> > > > > Thank you,
> > > > > Yiannis
> > > >
> > > > --
> > > > Claus Ibsen
> > > >
> > > > http://davsclaus.com @davsclaus
> > > > Camel in Action 2: https://www.manning.com/ibsen2
> >
> > --
> >
> > Claus Ibsen
> >
> > 
> >
> > http://davsclaus.com @davsclaus
> > Camel in Action 2: https://www.manning.com/ibsen2
>
>


-- 
Claus Ibsen
-
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2


Re: Kafka component Spring boot auto configuration

2018-12-05 Thread Yoshimo
Hey Claus,

I think that you misread my previous email. The value.deserializer = class 
org.apache.kafka.common.serialization.StringDeserializer line is the logging 
output of the Kafka consumer being created by Camel when I try adding the 
Spring Boot configuration.

What I actually add to my yaml file is the following:
camel.component.kafka.configuration.value-deserializer: 
com.openbet.platform.pricepublisher.serde.SportsEventDeserializer

The above is being ignored and the Kafka consumer that gets created by Camel 
has the default deserialer.

Thank you




‐‐‐ Original Message ‐‐‐
On Wednesday, 5 December 2018 14:17, Claus Ibsen  wrote:

> On Wed, Dec 5, 2018 at 12:56 PM Yoshimo yosh...@protonmail.com wrote:
>
> > Here is what I add to my yaml file:
> > camel.component.kafka.configuration.value-deserializer: 
> > com.openbet.platform.pricepublisher.serde.SportsEventDeserializer
> > and here is my route:
> >
> > from("kafka:prices?brokers={{kafka.servers}}")
> > .convertBodyTo(DBModel.class)
> > ..
> >
> >
> > With this setup when I start the app I can see in the logs the Kafka 
> > configuration in the consumer:
> > value.deserializer = class 
> > org.apache.kafka.common.serialization.StringDeserializer
>
> Try with
>
> value.deserializer = org.apache.kafka.common.serialization.StringDeserializer
>
> > and I get exceptions while deserializing. However if I remove the config 
> > from the yaml file and update my route to be:
> > kafka:prices?brokers={{kafka.servers}}=com.openbet.platform.pricepublisher.serde.SportsEventDeserializer
> > then I see the following in the Kafka consumer config:
> > value.deserializer = class 
> > com.openbet.platform.pricepublisher.serde.SportsEventDeserializer
> > and the app works as expected. Just for reference the rest of my yaml file 
> > is:
> > kafka:
> > sportsTopic: sports
> > pricesTopic: prices
> > servers: localhost:25445
> > streams:
> > "[application.id]": price-publisher
> > "[bootstrap.servers]": ${kafka.servers}
> > "[default.key.serde]": 
> > com.openbet.platform.pricepublisher.serde.ActivityKeySerDe
> > "[default.value.serde]": 
> > com.openbet.platform.pricepublisher.serde.ActivityValueSerDe
> > Thank you,
> > Yiannis
> > ‐‐‐ Original Message ‐‐‐
> > On Wednesday, 5 December 2018 13:30, Claus Ibsen claus.ib...@gmail.com 
> > wrote:
> >
> > > Hi
> > > Can you post your yaml configuration of how you try to configure this
> > > kafka value deserializer
> > > On Wed, Dec 5, 2018 at 11:36 AM Yoshimo yosh...@protonmail.com wrote:
> > >
> > > > Hello Claus,
> > > > thank you for looking into this.
> > > > Camel: 2.23.0
> > > > Kafka: 2.0.0
> > > > SB: 2.1.0.RELEASE
> > > > I am also attaching my pom if you want to have a look.
> > > > Thank you,
> > > > Yiannis
> > > > ‐‐‐ Original Message ‐‐‐
> > > > On Wednesday, 5 December 2018 12:15, Claus Ibsen claus.ib...@gmail.com 
> > > > wrote:
> > > >
> > > > > Hi
> > > > > What version of Camel, Kafka and SB are you using?
> > > > > On Tue, Dec 4, 2018 at 8:59 AM Yoshimo yosh...@protonmail.com.invalid 
> > > > > wrote:
> > > > >
> > > > > > Hello Camel users,
> > > > > > I am trying to auto configure the Kafka component using spring 
> > > > > > boot, but the configuration is not working. More specifically I am 
> > > > > > following this page:
> > > > > > https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc
> > > > > > and I am trying to set this configuration in my yaml file:
> > > > > > camel.component.kafka.configuration.value-deserializer
> > > > > > However the default deserializer is used when I consume from the 
> > > > > > Kafka topic. If I specify the deserializer in the Kafka route then 
> > > > > > it works as expected. Also I have defined the configuration 
> > > > > > camel.springboot.name in my yaml file and I can see that it is 
> > > > > > picked up normally. Are there any configurations that enable this 
> > > > > > functionality and I am missing?
> > > > > > Thank you,
> > > > > > Yiannis
> > > > >
> > > > > --
> > > > > Claus Ibsen
> > > > > http://davsclaus.com @davsclaus
> > > > > Camel in Action 2: https://www.manning.com/ibsen2
> > >
> > > --
> > > Claus Ibsen
> > >
> > > http://davsclaus.com @davsclaus
> > > Camel in Action 2: https://www.manning.com/ibsen2
>
> --
>
> Claus Ibsen
>
> 
>
> http://davsclaus.com @davsclaus
> Camel in Action 2: https://www.manning.com/ibsen2