Hi
I am not sure if the current camel-kafka supports this. You are
welcome to dive into the source code.
And if its not then welcome to log a JIRA and work on a patch.
Also the docs could use some love.
You can read here about how to help
http://camel.apache.org/contributing.html
On Wed, Apr 1,
Hi
The jetty component does not have serving static html files supported
out of the box.
There were some ppl in the community working on that.
But you can use a Camel processor / java bean / message transformation
eip to set the message body to a java.io.File or some input stream to
load a
Hi Jakub
Thanks for this. Its okay.
Though we like an unit test so it helps against regressions in the future.
On Fri, Apr 3, 2015 at 2:10 PM, Jakub Kotowski ja...@sindicetech.com wrote:
Hi Akram,
I've started to work with the Elasticsearch component recently so I had a
look at it for you.
You need the condition before the processor.
such as
interceptSendToEndpoint(mock:skippable).skipSendToOriginalEndpoint()
.when(body().isEqualTo(skip)).to(mock:detour);
On Fri, Apr 3, 2015 at 7:01 AM, Andrei Stoica
andrei.ionut.sto...@gmail.com wrote:
Hello. It seems
I am attempting to write a Custom Load Balancing policy based on the number
of Inflight messages per Endpoint. Basically, I want to return the
processor with the least number of Inflight messages. I understand these
metrics are available as JMX attributes. Is there a better approach than
I have quite interesting use case.we are using 2.12 camel version.
user will drop a below xml file where we need to read the xml file and
should poll the folder paths mentioned in the xml. user will place image
files in these folders.I can read the xml and all stuff
my question is how to
So we use the Kafka Consumer with multiple brokers
X.X.X.X:9092,X.X.X.X:9092,X.X.XX.X:9092
without any issue.
Derek
On Apr 4, 2015, at 8:23 AM, Claus Ibsen claus.ib...@gmail.com wrote:
Hi
I am not sure if the current camel-kafka supports this. You are
welcome to dive into the source
Hello,
can you try setting the annotation as below
@CsvRecord(separator = , , quote = \ , quoting= true )
the default value of quoting is set to false and hence doesnt appear as part
of the CSV
Regards,
-Yogesh
--
View this message in context:
My current thinking is to try leaving the code as-is, create multiple kafka
endpoints (one per broker) and then use the load-balancer EIP processor to
determine which endpoint(s) to send traffic through.
--
View this message in context:
