Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-12110

KafkaConsumer swallows exceptions from org.apache.kafka.clients.consumer.KafkaConsumer constructor

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.20.0
    • Fix Version/s: 2.20.2, 2.21.0
    • Component/s: camel-kafka
    • Labels:
      None
    • Estimated Complexity:
      Unknown

      Description

      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.

        Attachments

          Activity

            People

            • Assignee:
              davsclaus Claus Ibsen
              Reporter:
              lexsoto Alex Soto
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: