This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit fb845f88420162b396e5a87fdf31d31cefd8d689 Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Mon Oct 24 14:40:20 2022 +0200 CAMEL-18148: fixed incorrect interruption handling --- .../camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java b/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java index 744a5b1df05..e175b01fdc3 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java @@ -179,7 +179,7 @@ public class SingleNodeKafkaResumeStrategy implements KafkaResumeStrategy { } LOG.trace("Kafka resume strategy initialization complete"); } catch (InterruptedException e) { - throw new RuntimeException(e); + Thread.currentThread().interrupt(); } }