search

bootique / bootique-kafka

Provides integration of Kafka client and streams with Bootique
http://bootique.io
Apache License 2.0
4 stars 4 forks source link

Improve error reporting for a consumer #32

Open stariy95 opened 1 year ago

stariy95 commented 1 year ago

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.