Questions tagged [apache-camel]
Apache Camel is an open source integration framework that focuses on quick and easy integration of systems consuming or producing data.
11,719
questions
0
votes
0
answers
16
views
Apache Camel Websocket reverse proxy?
We have an app on Java + Spring boot + Apache camel, which runs as reverse proxy with request / response logic for SOAP and REST. I was asked to add weboskcet connections support. I'd like to know if ...
0
votes
0
answers
12
views
How to merge properly into a list of items in apache camel
Lets say I have the following message body:
<itemsList>
<item>
<id>1</id>
<name></name>
<description></description>
</item>
<...
0
votes
0
answers
15
views
Error with Javax.el dependency when deployed camel blueprint project in Karaf 4.4
I have a blueprint project in camel version 2.23 - Java 8
When I try to deploy to Karaf 4.4, I am getting the following error with the javax.el dependency:
Camel Blueprint
Camel context "...
0
votes
0
answers
18
views
Why would @BeanInject not be working with Java 17?
I use Apache Camel's BeanInject to initialize my rest template bean object. Like this:
@BeanInject("restTemplateBean") private RestTemplate RestTemplateBean;
RestTemplateBean is defined in ...
0
votes
0
answers
11
views
Spring Camel: Fhir Route without explicit serverUrl parameter on XML
I would like to remove serverUrl from my camel route fhir. The route works fine when I include the &serverUrl={{camel.component.fhir.server-url}} part in the URI, but I want to avoid this and I ...
0
votes
0
answers
19
views
Why is apache Camel TypeConverter needed for pojo that passes another pojo?
We have a GWT application were everything has to be serializable in order to pass back and forth between client and server. Everything was working fine with ActiveMQ 5.8.0 and Apache Camel 2.10.3. ...
0
votes
0
answers
36
views
How to inject mocks into a Camel route builder with Quarkus?
There's a Camel route builder registered in Quarkus and using some injected beans:
@ApplicationScoped
@RegisterForReflection
public class RouteForStoutBuilder extends RouteBuilder {
@Inject
...
0
votes
0
answers
25
views
Calling rest api secured with Bearer token authentication in Apache Camel route
I need to call a Rest API from my Apache Camel route. The Rest API is secured with a token that can be obtained on andother API.
My demo route looks like following:
from("direct:iot")
...
0
votes
0
answers
15
views
How do I define a global onCompletion camel route in xml?
According to Camel documentation a global onCompletion can be defined in xml, however when trying that I get: org.apache.camel.xml.io.XmlPullParserException: Unexpected element '{}onCompletion'
My ...
0
votes
1
answer
39
views
Can we use AdviceWith for non testing purpose?
We have scenario where we deliver our Camel application as jar to customer, and allow customer to create customisations to it, in some scenarios they might want to replace node in camel route,
Is it ...
-1
votes
0
answers
9
views
While consuming SOAP wsdl using camel, I'm getting this error [closed]
When I am trying to consume WSDL URL using camel, I should be able to consume whatever data present in the URL. But here the problem is, I have developed the code using apache camel , based on that ...
0
votes
0
answers
13
views
Apache camel JPA component multiple consumer environment, consume same message
I am using Apache camel JPA component as consumer. This consumer will be running in multi instance environment. Now I want to make sure consumer from each instance should not read same records, so ...
1
vote
0
answers
48
views
How to set up a workflow using Split, Aggregate and a single thread (3.11 migration issue)
I'm having issues migrating to Camel 3.21 from the 3.2 version.
My workflow looks like this:
read an XML file from FS -> parse it and split it into pieces -> aggregate those pieces into chunks ...
0
votes
0
answers
14
views
Apache Camel timer HTTP request fails with 'invalid proxy' error
I have a simple timer route which collects data from a http request. However after upgrading to camel-4.0.3 this no longer works, no body is fetched and the message is sent to the DLQ. Using camel-3....
0
votes
0
answers
18
views
kafkaProducer parameter not in JSON format
I am getting below error after upgread the java verison from 1.8 to 11
java.lang.IllegalArgumentException: kafkaProducer parameter not in JSON format:$propertySource.spring.cloud.stream.kafka.bindings....
0
votes
0
answers
8
views
Apache Camel - invalid char between encapsulated token and delimiter
I am getting the below sample csv response from Salesforce.
"Id","Success","Created","Error"
"","false","false","...
0
votes
1
answer
65
views
Apache Camel Kafka consumer consuming message even after pausing
I have a Kafka consumer in Camel route which consumes the message as below:
from("kafka:MykafkaTopic?brokers=localhost:9092&autoCommitEnable=false&allowManualCommit=true&...
0
votes
0
answers
51
views
Latest apache karaf camel (v3.21.2) is vulnerable to snakeyaml for CVE-2022-1471
Snakeyaml prior to v2.0 is vulnerable to CVE-2022-1471.
Latest Apache karaf camel is still using a vulnerable version of snakeyaml. See
https://mvnrepository.com/artifact/org.apache.camel.karaf/apache-...
0
votes
0
answers
11
views
How to handle/suppress apache camel FailedToStartRouteException for S3 route on invalid aws profile
The following code works fine with a valid AWS profile, but the Spring Boot application does not start when the AWS profile is invalid or does not exist in some environments. I just want to handle or ...
1
vote
2
answers
113
views
How to track unconsumed messages in kafka
I have a producer that producing messages to particular topic:
Producer:
// Produce a message to a Kafka topic
String topic = "dev.topic.proxy";
String key = "some-key&...
0
votes
0
answers
23
views
Jetty Large file upload OutOfMemoryError
What is the correct way to upload a large file in streaming mode (using multipart/form-data), i mean start processing file immediately without waiting for the entire file upload into memory using ...
0
votes
0
answers
19
views
Get white label page with status 404 using Apache Camel Servlet component
I am using Camel to provide a web service to other systems. I wrote a simple Camel consuming route to accept the http requests. I can successfully start the Camel application using Springboot. But ...
0
votes
0
answers
26
views
Quarkus using Apache Camel: MockEndpoint not working
I am using Apache Camel with Quarkus and I have some @QuarkusTest that use @MockEndpoint that stop to work after I upgraded from camel quarkus 2.7.0 to 2.16.0.
The tests look like:
@QuarkusTest
@...
0
votes
1
answer
42
views
Optional null with Apache Camel to get header parameters
Good morning.
Currently I am developing an API in Apache Camel in which I have to use queryParameters for the query and some parameters may be mandatory and others not, so I need to handle in case I ...
0
votes
0
answers
45
views
Where to Download Full Apache Camel Core JAR for OSGi Application with Ant Build System?
I am working on a Java OSGi application and need to include the Apache Camel Core library for Kafka message consumption. My project is built using Ant, and I am trying to manually download the ...
0
votes
1
answer
14
views
Using Camel JCachePolicy with Caffeine in OSGi Blueprint
I want to apply a camel-jcache route policy using a Caffeine cache in OSGi Blueprint. That policy allows to enclose a Camel route or part of a route with a caching facility, which ensures that the ...
0
votes
1
answer
36
views
Apache Camel & Springboot - 404 status - Response body blank when customer tries to reach an invalid/undefined endpoint
I am trying to have a custom json response body indicate to the customer that they tried to reach an invalid route. When they are missing a parameter in their request for ex. localhost:8080/hello//is/...
-1
votes
0
answers
16
views
doneFileName is not working with Apache AWS s3
camel route S3 uri is not working with donefileName
uri : aws2-s3://bucketName?amazonS3Client=#s3Client&doneFileName=${file:name}.done
where s3Client is spring boot bean with all configs
-1
votes
2
answers
62
views
Micrometer Component in Apache Camel - Metric not showing in /actuator/prometheus
I am currently working with Apache Camel and using the Micrometer component for metrics. I have added the necessary dependency, but I am facing an issue where the metric is not showing up in the /...
0
votes
0
answers
31
views
camel-netty4: io.netty.util.internal.OutOfDirectMemoryError
I've looked through all the previous times some version of this question has been asked.
Here's an overview of the answers.
Unanswered:
How to find a root cause of the following netty error: io.netty....
0
votes
1
answer
65
views
Split The body in Apache camel and Spring boot
I have a process like this to send some queries by body to the next process:
.process(exchange -> {
List<GlossaryDTOResponse[]> glossaries = exchange.getIn().getBody(List.class);
...
0
votes
0
answers
32
views
How to isolate subsequent Camel Spring-Boot test suites
I want to test my Spring-Boot/Camel application (Camel 4.1, Spring-Boot 3.1.5, JUnit5), which includes a Kafka consumer, or a producer, or both. I have written several JUnit test suites. When I run ...
0
votes
0
answers
20
views
Duplicate message consumption on Apache Camel Kafka
I am using the Kafka Consumer Component with Apache Camel 4.1.0 and Spring-Boot 3.1.5. To test message processing, I use a Kafka Testcontainer (one broker, one partition) and publish one test message ...
0
votes
1
answer
16
views
Timer properties not present on Exchange after upgrading to Camel 4.1
I am trying to upgrade from Camel 4.0 to 4.1, and none of the timer properties appear to be on the exchange. Were these moved somewhere else? The time does appear to work correctly.
Theses are the ...
-1
votes
0
answers
35
views
Consume Camel JMS queue with username and password throws SingleConnectionFactory error
When I try to consume from a JMS queue programmatically everything works fine, but when I try to use Apache Camel I always get the following error:
[Camel (camel-1) thread #1 - JmsConsumer[MySyncQueue]...
0
votes
0
answers
27
views
Apache Camel 4.1.0 Kubernetes Clustering - Leader election hanging after upgrade
I am upgrading an application which uses Camel leader election in Kubernetes.
https://camel.apache.org/manual/clustering.html
Upgrading from Spring boot 2 and camel version 3.0 to Spring boot 3 and ...
0
votes
1
answer
33
views
Unexpected EOF in prolog in Camel Xslt when input is InputStreamCache
Since version 3.17, Camel have automatic conversion to Stream Caches. When upgrading (from version 3.14 to version 4.0.2) we face a strange problem.
We use the Saxon Xslt component to transform Xml ...
-2
votes
0
answers
21
views
how to create variables in JSONATA expression and how to read apache camal created variables in JSONATA expression
I want to convert dataweave language script to JSONATA expressions.
In that I am getting data in variables in DWL.
I need to implements same variable functionality in JSONATA also.
And If I pass any ...
0
votes
1
answer
32
views
Service running without bean class in Tomcat, camel
I have limited knowledge of Java and tomcat and I am going through a service code base running on Apache tomcat, The service is using camel as the middleware integration framework. For one of the rest ...
0
votes
0
answers
15
views
apache-camel-salesforce: "Unknown operation name: pubSubSubscribe" testet in Version 4.0.0, 4.1.0 and 4.2.0-SNAPSHOT
I would like to capture a salesforce platform event "/event/UpdateAccount__e". With camel-salesforce-maven-plugin I can generate the correct sources (goal GeneraePubSub) for this event, so I ...
0
votes
0
answers
17
views
Kafka Camel service throwing SASLAuthenticationException for invalid credentials
I am using a kafka-camel-quarkus service which routes messages from one topic to another.
When the kafka client (due to some connectivity issues) restarts, the service which is up and running, starts ...
0
votes
0
answers
18
views
Camel PGP Decryption fails when armored is false
I have created a simple demo using Camel in order to encrypt/decrypt a PGP encrytion based file. The code is shown below.
package com.example.demo;
import org.apache.camel.CamelContext;
import org....
0
votes
0
answers
38
views
How to end-to-end test an Apache Camel Route with SEDA included?
I am writing an end-to-end test for my quarkus application that is using Apache Camel. I am basically receiving a message from a URI and sending it to a seda route with multiple consumers. This all ...
0
votes
0
answers
24
views
Execute apache camel route scheduler with multiple threads
I created new apache camel route scheduler and I want to be invoked by multiple threads on an interval. want to execute x number of threads. I am unsure how to go about it
public class TestRoute ...
0
votes
1
answer
40
views
Spring boot starter for camel rabbitmq v 4.x
It seems the new Apache camel LTS 4.0 doesn't provide an up-to-date version for org.apache.camel.springboot:camel-rabbitmq-starter
it seems the latest release is 3.21.2 here https://mvnrepository.com/...
0
votes
0
answers
39
views
Error in exchange property mapping to velocity template with Apache Camel upgrade 2.25+
I did Apache Camel velocity upgrade on my Spring boot application to 2.25.4
Now I am unable to access exchange properties from the velocity template. Just template is retrieved without values.
...
0
votes
0
answers
42
views
Camel Kafka consumer - is it possible to get multiple kafka messages in 1 shot and can manual commit
I have a route that listens to Kafka topic and calls a bean that takes in Exchange object containing the Kafka message. If I have 10 Kafka messages, my bean will be called 10 times each time the ...
0
votes
0
answers
20
views
Camel CXF on context startup
We're migrating our suits of applications from Camel 2 to Camel 4, I'm encountering several problem during the migration (as I expected) especially when we had to use the latest Wildlfy release and ...
0
votes
1
answer
88
views
Camel connecting multiple times to ActiveMQ Artemis
I am using Apache Camel to connect and subscribe to ActiveMQ Artemis feeds and forward to Kafka topics.
It runs fine for a while, but then stops with an exception:
jakarta.jms.JMSSecurityException: ...
0
votes
0
answers
21
views
I have a spring application exposing REST endpoints on both spring web and camel. My OpenAPI document can currently only document endpoints from one
I am running an application using Spring boot. I have dependencies for apache camel, open api and others.
I have defined a rest controller which exposes rest endpoints using the @RestController ...