Abhishek Jain created GOBBLIN-2177:
--------------------------------------
Summary: Avoid stopping Kafka HighLevelConsumer - QueueProcessor
on non-InterruptedExceptions
Key: GOBBLIN-2177
URL: https://issues.apache.org/jira/browse/GOBBLIN-2177
Project: Apache Gobblin
Issue Type: Bug
Reporter: Abhishek Jain
The QueueProcessor within HighLevelConsumer contains an infinite while loop
that is enclosed in a try-catch block. When any exception is encountered, this
loop breaks, which halts the processing of any consumed messages until the
service is restarted.
We should not break this infinite loop on all exceptions; rather, we should
break it only on InterruptedException, which truly means the QueueProcessor
should stop processing.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
