Hi
Thanks for all your findings, this is great insight. You are surely
welcome to create a JIRA ticket about this bug.
We can then together work on a fix, and you can help test it.
Yeah it seems catching KafkaException is maybe too wide. And lets see
if we also can incorporate bridge error
digging into the code (version 3.2.0 i repeat),
i can see in the class
`org.apache.camel.component.kafka.KafkaConsumer.KafkaFetchRecords.doRun`,
lign 406:
```
catch (KafkaException e) {
// some kind of error in kafka, it may happen during
// unsubscribing or during normal processing
if
I forgot to tell i am using version 3.2.0
On Sun, 26 Apr 2020 at 20:45, Joseph M'BIMBI-BENE
wrote:
> Hello everyone,
>
> I'm having a problem with the Kafka component:
> When the kafka consumer can't read a message (caused by some avro errors
> after investigation), it continuously leaves the
Hello everyone,
I'm having a problem with the Kafka component:
When the kafka consumer can't read a message (caused by some avro errors
after investigation), it continuously leaves the group and joins again.
I would like it to just throw an exception and let me decide how to handle
it: dlq,
I also realize that the property "bridgeErrorHandler" seems to never be
used, while another one, like "breakOnFirstError".
Also, going back to the exception handling, at least a couple other
subclasses of KafkaException would deserve not to be retried on. Just a few
examples:
-
When you're consuming file from S3, the name is set in the
header CamelAwsS3Key
So you could do something like
I didn't test this.
Il giorno lun 27 apr 2020 alle ore 14:34 Axel Bock <
axel.bock.mail+l...@gmail.com> ha scritto:
> hi list, since you (read: andrea ;) helped a lot on my last
Let me correct myself, it's
Il giorno lun 27 apr 2020 alle ore 15:11 Andrea Cosentino
ha scritto:
> When you're consuming file from S3, the name is set in the
> header CamelAwsS3Key
>
> So you could do something like
>
> />
>
>
> I didn't test this.
>
> Il giorno lun 27 apr 2020 alle ore
The Camel community announces the immediate availability of Apache
Camel-kafka-connector 0.1.0
The artifacts are published and ready for you to download either from
the Apache mirrors or from maven central.
For more info please visit the project GitHub repository[1].
Many thanks to all who made
hi list, since you (read: andrea ;) helped a lot on my last question, I
have another one. I consume files from s3. but the files are saved under
generic file names in my target directory, which I don't want. I actually
want to save them under the name they have in s3.
this is my config (broken up
Hello Camel Community
I am trying to use camel to query records based on mongo id with operation
"findById". Following is the route snippet
public void configure() throws Exception {
from("jetty:http://0.0.0.0:8081/mongo?httpMethodRestrict=GET;)
Thank you Sir.
You have given me what I needed.
An authoritative over view.
On Mon, 27 Apr 2020, 06:46 Ralf Claussnitzer, <
ralf.claussnit...@slub-dresden.de> wrote:
> Hi,
>
> On 4/26/20 9:50 PM, Som Lima wrote:
> > Hi,
> >
> > 1. What is a micro service ?
> I recommend you have a look at
Sorry.
I wish you good health and happiness
In these troubling times.
On Mon, 27 Apr 2020, 15:27 Som Lima, wrote:
> Thank you Sir.
> You have given me what I needed.
> An authoritative over view.
>
>
>
>
>
> On Mon, 27 Apr 2020, 06:46 Ralf Claussnitzer, <
> ralf.claussnit...@slub-dresden.de>
Is there way monitoring cpu and memory usage specific camelContext or
route?
13 matches
Mail list logo
