This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch prepare-1.17 in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git
commit 31a79493bde528a1201321f69786ff03baa49aca Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Tue Jan 24 08:38:35 2023 +0100 Upgrade Camel to version 3.20.1 Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- .../main/java/org/apache/camel/k/resume/kafka/KafkaResumeFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/camel-k-resume-kafka/impl/src/main/java/org/apache/camel/k/resume/kafka/KafkaResumeFactory.java b/camel-k-resume-kafka/impl/src/main/java/org/apache/camel/k/resume/kafka/KafkaResumeFactory.java index 13748af3..16f8e605 100644 --- a/camel-k-resume-kafka/impl/src/main/java/org/apache/camel/k/resume/kafka/KafkaResumeFactory.java +++ b/camel-k-resume-kafka/impl/src/main/java/org/apache/camel/k/resume/kafka/KafkaResumeFactory.java @@ -41,7 +41,7 @@ public final class KafkaResumeFactory { switch (name) { case "org.apache.camel.processor.resume.kafka.SingleNodeKafkaResumeStrategy": { - return new SingleNodeKafkaResumeStrategy<>(resumeStrategyConfiguration); + return new SingleNodeKafkaResumeStrategy(resumeStrategyConfiguration); } default: { throw new UnsupportedOperationException(String.format("The strategy %s is not a valid strategy", name));