vamossagar12 commented on PR #13594: URL: https://github.com/apache/kafka/pull/13594#issuecomment-1517696428
Thanks @yashmayya . I just tried to include only the ones which have a similar pattern. I think `SourceTaskOffsetCommitter` is something which can also be modified but I missed that. The one in `MemoryOffsetBackingStore` has some handling in cases on InterruptedException and infact throws ConnectException when it can't shutdown in time which is unlike what the newly added utils method does. Specifically on `Worker` I decided not to change because it was added as part of KAFKA-12380. As I said, I changed only those which were similar to the pattern the newly added Utils method had. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
