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!