[CAMEL-14919] DefaultCocsumerTemplate is not allowing to set the custom ExceptionHandler

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Won't Fix
• Affects Version/s: 2.25.0
• Fix Version/s: 3.x
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Sanojit Nayak
• Created: 16/Apr/20 08:19
• Updated: 18/May/20 13:46
• Resolved: 18/May/20 13:46

Description

We are using org.apache.camel.DefaultConsumerTemplate.receive(String endpointUri, long timeout) to consume the messages from a Kafka topic.

We are facing an issue, If we interrupt the current thread it is logging the exception by using “ org.apache.camel.util.CamelLogger”.

Therefore we don’t get any handle to set the custom exception handler for the Default Consumer created by ConsumerTemplate.

Exception Log :

org.apache.camel.util.CamelLogger log
WARNING: Interrupted while consuming RequestTopic-Thread 0 from kafka topic. Caused by: [org.apache.kafka.common.errors.InterruptException - java.lang.InterruptedException]
org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException