camel-kafka-consumercount-drops-to-1-default-from-the-defined-value

Hi All, Iam using kafka consumer in our application integrated with Camel(Camel-Kafka). We consume the messages and send the data to the server for processing. I have defined a topic "XYZ" defined with 30 partitions and I have assigned 15 as consumer count on each consumer node (total 2 instances

Upgrading to CamelCXF throws weird error

Hi All, I am getting the below error after upgrading to camel 3.0.0 Versions used in the POM *camel version* : 3.0.0 *cxf version* : 3.3.6 *ibm.mq library version* : 9.1.4.0 I am sending the message on an IBM MQ queue, I get the below error in the response in my logs. 2020-04-01

How to produce messages to Azure SQL DB in Camel

Team, I have a usecase where I need to replicate data for a specific duration from one Azure SQL DB (subscription1) to another Azure SQL DB (supbscription2). The source DB has live data with continuous inserts, updates and deletes possibility. Henceforth, we will miss the updates while performing

Re: How to produce messages to Azure SQL DB in Camel

/camel-examples/tree/master/examples/camel-example-debezium-eventhubs-blob > > >- Camel JDBC Example >< > https://github.com/apache/camel-examples/tree/master/examples/camel-example-jdbc > > >. > > I hope it helps! > > Regards, > Omar > >

Re: How to produce messages to Azure SQL DB in Camel

. > > Regards, > Omar > > On Fri, Dec 11, 2020 at 6:58 PM SRIKANT MVS wrote: > > > Thanks for your reply, how better is it to use the Camel SQL compared to > > Camel JDBC. > > > > -Regards > > Srikant > > > > On Thu, 10 Dec, 2020, 10:53 O

Can I call a PostgreSQL function from Camel-sql

Hi Team, I would like to call a DB function in PostgreSQL database using the camel-sql component. There are around 20-30 inParams that I would like to pass in a hashmap and get a single value in the outParams. I am unable to find any examples for the same. Additionally, I have to make this call fr

Re: Rép. : Re: Can I call a PostgreSQL function from Camel-sql

om Camel-sql > > Hi > > There’s documentation about the IN, OUT and INOUT parameters for that: > > > https://camel.apache.org/components/latest/sql-stored-component.html#_in_parameters > < > https://camel.apache.org/components/latest/sql-stored-component.html#_in_parameters >

Camel Springboot + telegraf-plugin + Grafana

Hi Team, I want to send metrics from my camel-springboot application to telegraf-plugins which would further be visible in the Grafana dashboard. This action should happen periodically. I have gone through the documentation and have enabled *camel-management* and *camel-metrics* dependency for sen

Re: Camel Springboot + telegraf-plugin + Grafana

021, 6:05 PM SRIKANT MVS wrote: > > > Hi Team, > > I want to send metrics from my camel-springboot application to > > telegraf-plugins which would further be visible in the Grafana dashboard. > > This action should happen periodically. > > > > I have gon

Kafka consumer wont recover after WakeupException

HI Team, I am using camel-kafka (version: 3.2.0) for consuming messages. Below is the flow 1. Kafka service consumes events from the topic 2. Make a call to the Server 3. When the server is not responding in 40ms, throw ServerUnavailableException 4. Stopping Kafka consumer on the t

Re: Kafka consumer wont recover after WakeupException

:37 PM Andrea Cosentino wrote: > Please try with an LTS version 3.7.x. 3.2.0 was a development version. > > Il giorno gio 1 apr 2021 alle ore 18:30 SRIKANT MVS > > ha scritto: > > > HI Team, > > > > I am using camel-kafka (version: 3.2.0) for consuming messages

Unable to set CXF CachedOutputStream.Threshold

Hi, I am using camel-cxf and have exposed soap service over HTTP using cxfEndpoint. There are few requests that are getting logged into the /tmp folder as the size is great than 64K-128K. I want to increase the memory size greater than 128K so that the request does not gets saved in the /tmp folder

Unable to set CXF CachedOutputStream.Threshold

spring-config.xml file. -Regards Srikant Mantha -- Forwarded message - From: SRIKANT MVS Date: Wed, Apr 28, 2021 at 7:18 PM Subject: Unable to set CXF CachedOutputStream.Threshold To: Hi, I am using camel-cxf and have exposed soap service over HTTP using cxfEndpoint. There are

Re: Unable to set CXF CachedOutputStream.Threshold

. > > Did you find this information on a link to Apache CXF or someplace > else? I ask because we could maybe add a section to the camel-cxf doc > page talking about this and with a link to more details at Apache CXF. > > On Sun, May 2, 2021 at 8:34 AM SRIKANT MVS wrote: > &

Stop JMS Consumers in Camel-CXF on Exception using camel route policy

Hi Team, I am using a camel-cxf application where I have exposed cxfEndpoints for SOAP over HTTP and SOAP over JMS. I am consuming events from IBM MQ and publishing them to a WebService. I want to implement the circuit break pattern when my WebService is not reachable. Ideally it should not con

Re: Kafka consumer wont recover after WakeupException

6:44 PM SRIKANT MVS wrote: > Hi Andrea/Claus, > Thanks for the quick response. I am seeing this issue from camel 3.1.0, > also migration to camel 3.4.5 (java 8 support) and kafka client upgraded to > 2.5.0. Still the same issue is seen. > > Let me also give a try upgrading

How to setup metrics on camel-springboot non-web application

Hello, I am running a kafka consumer application using camel-spring-boot-starter. The SpringBoot application implements CommandLineRunner. The below property is configured in my application. camel.springboot.main-run-controller=true I am trying to expose the springboot actuator metrics on the po

Re: How to setup metrics on camel-springboot non-web application

Yes Mark, Spring-web dependency is also added, still not working. -Regards Srikant On Mon, 21 Jun, 2021, 19:16 Mark Nuttall, wrote: > For an app to expose http endpoints, it has to be a "web app". > > Why not just add the spring boot web dependency? > > On Mon, Jun 21,

Re: How to setup metrics on camel-springboot non-web application

2.x you have to enable all/each endpoint using the > property *management.endpoints.web.exposure.include=** (or if you just want > metrics, replace *** with *metrics*) > > By default, spring boot only enables the /actuator/health and > /actuator/info. > On Mon, 21 Jun 2021, 2

Re: How to setup metrics on camel-springboot non-web application

ath as /app/metrics. If you want metrics at the > /actuator endpoint then you'll have to remove the > management.endpoints.web.base-path=/app/metrics property. > > Refer > > https://docs.spring.io/spring-boot/docs/2.1.11.RELEASE/reference/html/production-ready-monitoring.html

Change of email for subscription

Hi Team, I would like to change my email address for subscribing to the camel user queries to mantha.srik...@outlook.com. Kindly do the needful. -Thanks Srikant Mantha