RE: Camel kafka multiple consumer question

Hi, How did you manage to change the partition Key when producing the messages, coz. when I tried to change the partition Key as part of the header in the messages , getting this error ... org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[Me

SQL Batch Consumer

Hello, I have a route with batch consumer that I want to execute manually. The route will read information using a SQL statement, aggregate the result rows by ticket_nbr, and force complete each aggregated group after all the rows have been aggregated. Here is what I have so far: from("sql:class

Re: camel restlet usage

I tried to use the same port and got these errors below, so no go there. org.apache.camel.RuntimeCamelException: java.net.BindException: Address already in use at org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1642) at org.apache.camel.spring.SpringCa

Referring to non-existent enum in simple expression results in null instead of error

Hi everyone, In the Camel documentation for the simple expression language I learned that I can refer to enums. I used this to pass an enum to some bean in my route. Here is a snippet of Java DSL: .bean(SomeBean.class, "process(*, ${type:package.SomeEnumT

Re: camel restlet usage

Thank you for the input Souciance. I'll give it a try and switch to the same port. -- View this message in context: http://camel.465427.n5.nabble.com/camel-restlet-usage-tp5785477p5785502.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Suggestions on how to cluster Camel?

There is no one answer to your question. Different endpoints support different options for clustering and fail over. I do cover those topics in the following chapters of Camel Design Patterns book: 15. Service Instance Pattern 16. Singleton Service Pattern And here are some related posts: http:

camel-jdbc and transction manager support

Hi, I'm trying to understand if camel-jdbc can work under the coordination of a transaction manager. I have found this old JIRA: https://issues.apache.org/jira/browse/CAMEL-3803 And not much more in git history of JdbcProducer class. Can anyone confirm?

Howto save data with camel-mongodb

Hi, I try to use save operation on mongodb componant. my route is simple from http to mongo like this when I post a simple JSON data I'm get the response the data is inserted in database. but i want to post data for update operation I've send exactly the response with "cool":"MongoDB" But the the

camel-mongoDB Mongo class as osgi service

I'm using camel-mongodb in many osgi bundles each bundle declare its own Mongo bean. I want to share Mongo connexion as osgi service. but com.mongodb.Mongo does not implement any interface. I try to reférence the service with ext:proxy-method="classes" but it failed how to use the same connectio