We noticed that some errors were happening in one of our KafkaStreams
jobs but they were not appearing in our logs or being sent to our
error reporting service (Airbrake) -- they only became visible on
stdout when running from the console. I believe the reason is because
of this explicit catch-rethrow of KafkaExceptions in the main run loop
of the StreamThread:

https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java#L219

What's the proper way for these exceptions to be getting logged? The
comment indicates they should be getting logged but they are not being
processed by our loggers in log4j.properties. Here is our properties
file:

https://gist.github.com/gfodor/7d9a2102bde5f2dc062ead4e9551e670

Thanks!

Reply via email to