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 6d82a8f430371bcf5b808eaa6c3d71fbf18c9899 Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Mon Oct 24 14:41:16 2022 +0200 CAMEL-18148: API cleanups --- .../processor/resume/kafka/SingleNodeKafkaResumeStrategy.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) 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 e175b01fdc3..6518311f76e 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 @@ -25,7 +25,6 @@ import java.util.Collection; import java.util.Collections; import java.util.Objects; import java.util.concurrent.CountDownLatch; -import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; @@ -95,13 +94,10 @@ public class SingleNodeKafkaResumeStrategy implements KafkaResumeStrategy { * Sends data to a topic. The records will always be sent asynchronously. If there's an error, a producer error * counter will be increased. * - * @param message the message to send - * @throws ExecutionException - * @throws InterruptedException + * @param message the message to send * */ - protected void produce(byte[] key, byte[] message, UpdateCallBack updateCallBack) - throws ExecutionException, InterruptedException { + protected void produce(byte[] key, byte[] message, UpdateCallBack updateCallBack) { ProducerRecord<byte[], byte[]> record = new ProducerRecord<>(resumeStrategyConfiguration.getTopic(), key, message); producer.send(record, (recordMetadata, e) -> {