gharris1727 commented on PR #14316: URL: https://github.com/apache/kafka/pull/14316#issuecomment-1703060492
@C0urante Thanks for mentioning `InterruptException`, that can certainly appear as a RuntimeException when plugins are using Kafka clients internally. You mention the converter and transformations, those plugins would also affected by this change. While it may not be typical for a converter or transformation to contain a sleep() or other blocking operation, it certainly can happen. This (and interrupt-on-stop) would be a broad-spectrum change for all plugins. The early-exit you mention would complicate the control flow slightly, so we'll have to take care to make sure that partially-transformed records are discarded correctly. I agree that we should have a community discussion about implementing interrupt-on-stop. I have a feeling that we don't need to block interrupt-on-cancel for that discussion, as the change seems more unambiguously beneficial. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
