You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/10/24 13:57:44 UTC
[camel] 05/05: CAMEL-18148: API cleanups
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 <an...@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) -> {