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/03/08 12:51:44 UTC
[camel] 03/09: CAMEL-17763: cleaned up unused exceptions in camel-kafka
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 9a4d3556fc2448a34e096ccfbcf4cad7e0ed4a0d
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 12:18:44 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-kafka
---
.../apache/camel/component/kafka/KafkaComponentTest.java | 8 ++++----
.../apache/camel/component/kafka/KafkaConsumerTest.java | 4 ++--
.../apache/camel/component/kafka/KafkaProducerTest.java | 4 ++--
.../integration/KafkaConsumerAsyncManualCommitIT.java | 2 +-
.../kafka/integration/KafkaConsumerBatchSizeIT.java | 4 ++--
.../component/kafka/integration/KafkaConsumerFullIT.java | 7 +++----
.../kafka/integration/KafkaConsumerHealthCheckIT.java | 5 ++---
.../kafka/integration/KafkaConsumerIdempotentIT.java | 8 +++-----
.../KafkaConsumerIdempotentWithCustomSerializerIT.java | 6 ++----
.../KafkaConsumerIdempotentWithProcessorIT.java | 8 +++-----
.../integration/KafkaConsumerLastRecordHeaderIT.java | 4 ++--
.../kafka/integration/KafkaConsumerManualCommitIT.java | 4 ++--
.../kafka/integration/KafkaConsumerRebalanceIT.java | 6 +++---
.../kafka/integration/KafkaConsumerTopicIsPatternIT.java | 4 ++--
.../KafkaConsumerWithResumeRouteStrategyIT.java | 4 ++--
.../component/kafka/integration/KafkaProducerFullIT.java | 15 +++++++--------
.../camel/component/kafka/integration/KafkaToDIT.java | 6 +++---
.../kafka/KafkaIdempotentRepositoryEagerIT.java | 8 ++++----
.../kafka/KafkaIdempotentRepositoryNonEagerIT.java | 8 ++++----
.../kafka/KafkaIdempotentRepositoryPersistenceIT.java | 2 +-
20 files changed, 54 insertions(+), 63 deletions(-)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
index b95efcb..53cc175 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
@@ -36,7 +36,7 @@ import static org.junit.jupiter.api.Assertions.assertNull;
public class KafkaComponentTest extends CamelTestSupport {
@Test
- public void testPropertiesSet() throws Exception {
+ public void testPropertiesSet() {
String uri = "kafka:mytopic?brokers=broker1:12345,broker2:12566&partitioner=com.class.Party";
KafkaEndpoint endpoint = context.getEndpoint(uri, KafkaEndpoint.class);
@@ -46,7 +46,7 @@ public class KafkaComponentTest extends CamelTestSupport {
}
@Test
- public void testBrokersOnComponent() throws Exception {
+ public void testBrokersOnComponent() {
KafkaComponent kafka = context.getComponent("kafka", KafkaComponent.class);
kafka.getConfiguration().setBrokers("broker1:12345,broker2:12566");
@@ -255,7 +255,7 @@ public class KafkaComponentTest extends CamelTestSupport {
}
@Test
- public void testCreateProducerConfigTruststorePassword() throws Exception {
+ public void testCreateProducerConfigTruststorePassword() {
KeyStoreParameters keyStoreParameters = new KeyStoreParameters();
keyStoreParameters.setPassword("my-password");
@@ -275,7 +275,7 @@ public class KafkaComponentTest extends CamelTestSupport {
}
@Test
- public void testCreateConsumerConfigTruststorePassword() throws Exception {
+ public void testCreateConsumerConfigTruststorePassword() {
KeyStoreParameters keyStoreParameters = new KeyStoreParameters();
keyStoreParameters.setPassword("my-password");
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java
index 7171264..426f12b 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java
@@ -38,7 +38,7 @@ public class KafkaConsumerTest {
private ExchangeFactory ef = mock(ExchangeFactory.class);
@Test
- public void consumerRequiresBootstrapServers() throws Exception {
+ public void consumerRequiresBootstrapServers() {
when(endpoint.getCamelContext()).thenReturn(ecc);
when(ecc.adapt(ExtendedCamelContext.class)).thenReturn(ecc);
when(ecc.getExchangeFactory()).thenReturn(ef);
@@ -55,7 +55,7 @@ public class KafkaConsumerTest {
}
@Test
- public void consumerOnlyRequiresBootstrapServers() throws Exception {
+ public void consumerOnlyRequiresBootstrapServers() {
when(endpoint.getCamelContext()).thenReturn(ecc);
when(ecc.adapt(ExtendedCamelContext.class)).thenReturn(ecc);
when(ecc.getExchangeFactory()).thenReturn(ef);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
index ec2750d..3261e2a 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
@@ -107,7 +107,7 @@ public class KafkaProducerTest {
}
@Test
- public void testPropertyBuilder() throws Exception {
+ public void testPropertyBuilder() {
Properties props = producer.getProps();
assertEquals("broker1:1234,broker2:4567", props.getProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG));
}
@@ -142,7 +142,7 @@ public class KafkaProducerTest {
}
@Test
- public void processAsyncSendsMessage() throws Exception {
+ public void processAsyncSendsMessage() {
endpoint.getConfiguration().setTopic("sometopic");
Mockito.when(exchange.getIn()).thenReturn(in);
Mockito.when(exchange.getMessage()).thenReturn(in);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
index 6f2a642..dc82ca2 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
@@ -73,7 +73,7 @@ public class KafkaConsumerAsyncManualCommitIT extends BaseEmbeddedKafkaTestSuppo
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java
index b3b366b..2229811 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java
@@ -56,10 +56,10 @@ public class KafkaConsumerBatchSizeIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo").to(to).setId("First");
}
};
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
index f772423..2e0792e 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.kafka.integration;
-import java.io.IOException;
import java.util.Collections;
import java.util.Map;
import java.util.Properties;
@@ -84,7 +83,7 @@ public class KafkaConsumerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
@@ -97,7 +96,7 @@ public class KafkaConsumerFullIT extends BaseEmbeddedKafkaTestSupport {
@Order(3)
@Test
- public void kafkaMessageIsConsumedByCamel() throws InterruptedException, IOException {
+ public void kafkaMessageIsConsumedByCamel() throws InterruptedException {
String propagatedHeaderKey = "PropagatedCustomHeader";
byte[] propagatedHeaderValue = "propagated header value".getBytes();
String skippedHeaderKey = "CamelSkippedHeader";
@@ -128,7 +127,7 @@ public class KafkaConsumerFullIT extends BaseEmbeddedKafkaTestSupport {
@Order(2)
@Test
- public void kafkaRecordSpecificHeadersAreNotOverwritten() throws InterruptedException, IOException {
+ public void kafkaRecordSpecificHeadersAreNotOverwritten() throws InterruptedException {
String propagatedHeaderKey = KafkaConstants.TOPIC;
byte[] propagatedHeaderValue = "propagated incorrect topic".getBytes();
to.expectedHeaderReceived(KafkaConstants.TOPIC, TOPIC);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
index d5e973c..a115113 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.kafka.integration;
-import java.io.IOException;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
@@ -110,7 +109,7 @@ public class KafkaConsumerHealthCheckIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
@@ -123,7 +122,7 @@ public class KafkaConsumerHealthCheckIT extends BaseEmbeddedKafkaTestSupport {
@Order(1)
@Test
- public void kafkaConsumerHealthCheck() throws InterruptedException, IOException {
+ public void kafkaConsumerHealthCheck() throws InterruptedException {
// health-check liveness should be UP
Collection<HealthCheck.Result> res = HealthCheckHelper.invokeLiveness(context);
boolean up = res.stream().allMatch(r -> r.getState().equals(HealthCheck.State.UP));
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
index b954fa4..2976de3 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
@@ -17,8 +17,6 @@
package org.apache.camel.component.kafka.integration;
import java.util.Arrays;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeoutException;
import org.apache.camel.BindToRegistry;
import org.apache.camel.Endpoint;
@@ -57,7 +55,7 @@ public class KafkaConsumerIdempotentIT extends KafkaConsumerIdempotentTestSuppor
private int size = 200;
@BeforeEach
- public void before() throws ExecutionException, InterruptedException, TimeoutException {
+ public void before() {
kafkaAdminClient.deleteTopics(Arrays.asList(TOPIC, "TEST_IDEMPOTENT")).all();
doSend(size, TOPIC);
}
@@ -68,12 +66,12 @@ public class KafkaConsumerIdempotentIT extends KafkaConsumerIdempotentTestSuppor
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo")
.idempotentConsumer(numericHeader("id"))
.idempotentRepository("kafkaIdempotentRepository")
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
index 2608054..2e80a8d 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
@@ -17,8 +17,6 @@
package org.apache.camel.component.kafka.integration;
import java.util.Arrays;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeoutException;
import org.apache.camel.BindToRegistry;
import org.apache.camel.Endpoint;
@@ -53,7 +51,7 @@ public class KafkaConsumerIdempotentWithCustomSerializerIT extends KafkaConsumer
private int size = 200;
@BeforeEach
- public void before() throws ExecutionException, InterruptedException, TimeoutException {
+ public void before() {
kafkaIdempotentRepository.clear();
kafkaAdminClient.deleteTopics(Arrays.asList(TOPIC, "TEST_IDEMPOTENT")).all();
doSend(size, TOPIC);
@@ -65,7 +63,7 @@ public class KafkaConsumerIdempotentWithCustomSerializerIT extends KafkaConsumer
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
index 95dc245..4a5f9ff 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
@@ -18,8 +18,6 @@ package org.apache.camel.component.kafka.integration;
import java.math.BigInteger;
import java.util.Arrays;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeoutException;
import org.apache.camel.BindToRegistry;
import org.apache.camel.Endpoint;
@@ -52,7 +50,7 @@ public class KafkaConsumerIdempotentWithProcessorIT extends KafkaConsumerIdempot
private int size = 200;
@BeforeEach
- public void before() throws ExecutionException, InterruptedException, TimeoutException {
+ public void before() {
kafkaIdempotentRepository.clear();
kafkaAdminClient.deleteTopics(Arrays.asList(TOPIC, "TEST_IDEMPOTENT")).all();
doSend(size, TOPIC);
@@ -65,12 +63,12 @@ public class KafkaConsumerIdempotentWithProcessorIT extends KafkaConsumerIdempot
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("idemp-with-prop")
.process(exchange -> {
byte[] id = exchange.getIn().getHeader("id", byte[].class);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java
index 13ec664..5d30d5e 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java
@@ -84,10 +84,10 @@ public class KafkaConsumerLastRecordHeaderIT extends BaseEmbeddedKafkaTestSuppor
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("kafka:" + TOPIC + "?groupId=A&autoOffsetReset=earliest&autoCommitEnable=false").to("mock:result");
}
};
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java
index 5334aa5..e57e25f 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java
@@ -65,11 +65,11 @@ public class KafkaConsumerManualCommitIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo").to(to).process(e -> {
KafkaManualCommit manual = e.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
assertNotNull(manual);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java
index 4fbef30..b56211f 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java
@@ -43,7 +43,7 @@ public class KafkaConsumerRebalanceIT extends BaseEmbeddedKafkaTestSupport {
private CountDownLatch messagesLatch;
@Override
- protected void doPreSetup() throws Exception {
+ protected void doPreSetup() {
messagesLatch = new CountDownLatch(1);
stateRepository = new OffsetStateRepository(messagesLatch);
}
@@ -63,10 +63,10 @@ public class KafkaConsumerRebalanceIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("kafka:" + TOPIC + "?groupId=" + TOPIC + "_GROUP" + "&autoCommitIntervalMs=1000"
+ "&autoOffsetReset=latest" + "&consumersCount=1"
+ "&offsetRepository=#offset").routeId("consumer-rebalance-route").to("mock:result");
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
index 5c4702a..ebe39dc 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
@@ -65,11 +65,11 @@ public class KafkaConsumerTopicIsPatternIT extends BaseEmbeddedKafkaTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).to(to);
}
};
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java
index dbc9d91..02bccec 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java
@@ -216,10 +216,10 @@ public class KafkaConsumerWithResumeRouteStrategyIT extends BaseEmbeddedKafkaTes
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("kafka:" + TOPIC + "?groupId=" + TOPIC + "_GROUP&autoCommitIntervalMs=1000"
+ "&autoOffsetReset=earliest&consumersCount=1")
.routeId("resume-strategy-route")
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
index e62fe61..c17cd47 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.kafka.integration;
-import java.io.IOException;
import java.nio.ByteBuffer;
import java.time.Duration;
import java.util.ArrayList;
@@ -141,10 +140,10 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:startStrings").to(toStrings).to(mockEndpoint);
from("direct:startStrings2").to(toStrings2).to(mockEndpoint);
@@ -161,7 +160,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedStringMessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedStringMessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -192,7 +191,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedString2MessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedString2MessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -223,7 +222,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedStringMessageIsIntercepted() throws InterruptedException, IOException {
+ public void producedStringMessageIsIntercepted() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -244,7 +243,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedStringCollectionMessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedStringCollectionMessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -290,7 +289,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedBytesMessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedBytesMessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java
index 5037895..8234d5c 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java
@@ -24,7 +24,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class KafkaToDIT extends BaseEmbeddedKafkaTestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
@@ -34,10 +34,10 @@ public class KafkaToDIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("kafka://${header.where}");
}
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java
index 9fb1e4e8..a859306 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java
@@ -46,10 +46,10 @@ public class KafkaIdempotentRepositoryEagerIT extends BaseEmbeddedKafkaTestSuppo
private MockEndpoint mockBefore;
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:in").to("mock:before").idempotentConsumer(header("id"))
.idempotentRepository("kafkaIdempotentRepository").to("mock:out").end();
}
@@ -57,7 +57,7 @@ public class KafkaIdempotentRepositoryEagerIT extends BaseEmbeddedKafkaTestSuppo
}
@Test
- public void testRemovesDuplicates() throws InterruptedException {
+ public void testRemovesDuplicates() {
for (int i = 0; i < 10; i++) {
template.sendBodyAndHeader("direct:in", "Test message", "id", i % 5);
}
@@ -69,7 +69,7 @@ public class KafkaIdempotentRepositoryEagerIT extends BaseEmbeddedKafkaTestSuppo
}
@Test
- public void testRollsBackOnException() throws InterruptedException {
+ public void testRollsBackOnException() {
mockOut.whenAnyExchangeReceived(exchange -> {
int id = exchange.getIn().getHeader("id", Integer.class);
if (id == 0) {
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java
index a4f3690..ba3563f 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java
@@ -48,10 +48,10 @@ public class KafkaIdempotentRepositoryNonEagerIT extends BaseEmbeddedKafkaTestSu
private MockEndpoint mockBefore;
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:in").to("mock:before").idempotentConsumer(header("id"))
.idempotentRepository("kafkaIdempotentRepository").eager(false).to("mock:out").end();
}
@@ -59,7 +59,7 @@ public class KafkaIdempotentRepositoryNonEagerIT extends BaseEmbeddedKafkaTestSu
}
@Test
- public void testRemovesDuplicates() throws InterruptedException {
+ public void testRemovesDuplicates() {
for (int i = 0; i < 10; i++) {
template.sendBodyAndHeader("direct:in", "Test message", "id", i % 5);
}
@@ -71,7 +71,7 @@ public class KafkaIdempotentRepositoryNonEagerIT extends BaseEmbeddedKafkaTestSu
}
@Test
- public void testRollsBackOnException() throws InterruptedException {
+ public void testRollsBackOnException() {
mockOut.whenAnyExchangeReceived(exchange -> {
int id = exchange.getIn().getHeader("id", Integer.class);
if (id == 0) {
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java
index 98b82f7..dfb8d8e 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java
@@ -65,7 +65,7 @@ public class KafkaIdempotentRepositoryPersistenceIT extends BaseEmbeddedKafkaTes
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {