Exceptions that are thrown in the callback provided to the KafkaConsumerBuilder.consume() method are silently discarded inside Kafka stack and event processing just stops. We could try to catch those and at least report them, so it could save some time understanding what is going on.
Exceptions that are thrown in the callback provided to the
KafkaConsumerBuilder.consume()method are silently discarded inside Kafka stack and event processing just stops. We could try to catch those and at least report them, so it could save some time understanding what is going on.