Description
KAFKA-12462 introduced a change that increased this "Thread state is already {}" logger to info instead of debug. We are running into a problem with our streams apps when they hit an unrecoverable exception that shuts down the streams thread, we get this log printed about 50,000 times per second per thread. I am guessing it is once per record we have queued up when the exception happens? We have temporarily raised the StreamThread logger to WARN instead of INFO to avoid the spam, but we do miss the other good logs we get on INFO in that class. Could this log be reverted back to debug? Thank you!
Attachments
Issue Links
- links to