Hi,

I'm trying to understand the error handling in Apache Camel. I have defined
a route to processes Kafka messages and I want the fetching to keep trying
forever, but to ignore exceptions from the processor. So I have this setup:

                from(notificationSystemInboundEndpoint)

                    .onException(Exception.class)

                        .maximumRedeliveries(-1)

                    .end()

                    .process(processor)

                    .onException(Exception.class)

                    .maximumRedeliveries(0)

                    .logStackTrace(true)

                    .handled(true);


I'm not sure this is correct. What would be the best way to do this?


Thank you,

Carlos.

Reply via email to