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 <[email protected]> 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() {
