Alex Soto created CAMEL-12110:
---------------------------------
Summary: KafkaConsumer swallows exceptions from
org.apache.kafka.clients.consumer.KafkaConsumer constructor
Key: CAMEL-12110
URL: https://issues.apache.org/jira/browse/CAMEL-12110
Project: Camel
Issue Type: Improvement
Components: camel-kafka
Affects Versions: 2.20.0
Reporter: Alex Soto
When an exception is thrown by the
_org.apache.kafka.clients.consumer.KafkaConsumer_ constructor when instantiated
by the _KafkaConsumer_ inner class _KafkaFetchRecords_, the exception is not
logged, nor propagated. This can happen, for example, if the key or the value
deserializer class names are incorrect, or the class is not found by the class
loader.
I would expect the exception here should cause the endpoint to fail
initializing, or at a minimum, the exception should be logged. The fact that
nothing is logged and the route is started without any apparent error, is
misleading and very hard to troubleshoot.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
