diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtilsTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtilsTests.java index 0a1ee3fc8..8c054cbdb 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtilsTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtilsTests.java @@ -29,7 +29,7 @@ import static org.assertj.core.api.Assertions.assertThat; class KafkaStreamsBinderUtilsTests { @Test - void testDeriveFunctionUnitsWithVariedSpacings() { + void deriveFunctionUnitsWithVariedSpacings() { final String definition = "firstFunction; secondFunction; thirdFunction;fourthFunction"; final String[] functionUnits = KafkaStreamsBinderUtils.deriveFunctionUnits(definition); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsEventTypeRoutingTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsEventTypeRoutingTests.java index 19ddf5e60..a6309c736 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsEventTypeRoutingTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsEventTypeRoutingTests.java @@ -84,7 +84,7 @@ class KafkaStreamsEventTypeRoutingTests { //See https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1003 for more context on this test. @Test - void testRoutingWorksBasedOnEventTypes() { + void routingWorksBasedOnEventTypes() { SpringApplication app = new SpringApplication(EventTypeRoutingTestConfig.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -154,7 +154,7 @@ class KafkaStreamsEventTypeRoutingTests { } @Test - void testRoutingWorksBasedOnEventTypesConsumer() throws Exception { + void routingWorksBasedOnEventTypesConsumer() throws Exception { SpringApplication app = new SpringApplication(EventTypeRoutingTestConfig.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionCompositionTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionCompositionTests.java index df8c23a08..a6015c35c 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionCompositionTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionCompositionTests.java @@ -80,7 +80,7 @@ class KafkaStreamsFunctionCompositionTests { } @Test - void testBasicFunctionCompositionWithDefaultDestination() throws InterruptedException { + void basicFunctionCompositionWithDefaultDestination() throws InterruptedException { SpringApplication app = new SpringApplication(FunctionCompositionConfig1.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -114,7 +114,7 @@ class KafkaStreamsFunctionCompositionTests { } @Test - void testBasicFunctionCompositionWithDestinaion() throws InterruptedException { + void basicFunctionCompositionWithDestinaion() throws InterruptedException { SpringApplication app = new SpringApplication(FunctionCompositionConfig1.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -214,7 +214,7 @@ class KafkaStreamsFunctionCompositionTests { } @Test - void testChainedFunctionsAsComposed() throws InterruptedException { + void chainedFunctionsAsComposed() throws InterruptedException { SpringApplication app = new SpringApplication(FunctionCompositionConfig4.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -257,7 +257,7 @@ class KafkaStreamsFunctionCompositionTests { } @Test - void testFirstFunctionCurriedThenComposeWithOtherFunctions() throws InterruptedException { + void firstFunctionCurriedThenComposeWithOtherFunctions() throws InterruptedException { SpringApplication app = new SpringApplication(FunctionCompositionConfig5.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java index 4746c7c28..923aec9d6 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java @@ -121,7 +121,7 @@ class KafkaStreamsBinderBootstrapTest { @Test @SuppressWarnings("unchecked") - void testStreamConfigGlobalProperties_GH1149() { + void streamConfigGlobalProperties_GH1149() { ConfigurableApplicationContext applicationContext = new SpringApplicationBuilder( SimpleKafkaStreamsApplication.class).web(WebApplicationType.NONE).run( "--spring.cloud.function.definition=input1;input2;input3", diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java index 18c00c077..5e0140c36 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java @@ -65,7 +65,7 @@ class KafkaStreamsBinderJaasInitTests { } @Test - void testKafkaStreamsBinderJaasInitialization() { + void kafkaStreamsBinderJaasInitialization() { ConfigurableApplicationContext applicationContext = new SpringApplicationBuilder( KafkaStreamsBinderJaasInitTestsApplication.class).web(WebApplicationType.NONE).run( "--spring.cloud.function.definition=foo", diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountBranchesFunctionTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountBranchesFunctionTests.java index d62bcbe8b..93ebb818c 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountBranchesFunctionTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountBranchesFunctionTests.java @@ -75,7 +75,7 @@ class KafkaStreamsBinderWordCountBranchesFunctionTests { } @Test - void testKstreamWordCountWithStringInputAndPojoOuput() throws Exception { + void kstreamWordCountWithStringInputAndPojoOuput() throws Exception { SpringApplication app = new SpringApplication(WordCountProcessorApplication.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java index 758fee0db..132a59c6b 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java @@ -98,7 +98,7 @@ class KafkaStreamsBinderWordCountFunctionTests { @Test @SuppressWarnings("unchecked") - void testBasicKStreamTopologyExecution() throws Exception { + void basicKStreamTopologyExecution() throws Exception { SpringApplication app = new SpringApplication(WordCountProcessorApplication.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -175,7 +175,7 @@ class KafkaStreamsBinderWordCountFunctionTests { } @Test - void testKstreamWordCountWithApplicationIdSpecifiedAtDefaultConsumer() { + void kstreamWordCountWithApplicationIdSpecifiedAtDefaultConsumer() { SpringApplication app = new SpringApplication(WordCountProcessorApplication.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -196,7 +196,7 @@ class KafkaStreamsBinderWordCountFunctionTests { } @Test - void testKstreamWordCountFunctionWithCustomProducerStreamPartitioner() throws Exception { + void kstreamWordCountFunctionWithCustomProducerStreamPartitioner() throws Exception { SpringApplication app = new SpringApplication(WordCountProcessorApplication.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -236,7 +236,7 @@ class KafkaStreamsBinderWordCountFunctionTests { } @Test - void testKstreamBinderAutoStartup() throws Exception { + void kstreamBinderAutoStartup() throws Exception { SpringApplication app = new SpringApplication(WordCountProcessorApplication.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -258,7 +258,7 @@ class KafkaStreamsBinderWordCountFunctionTests { } @Test - void testKstreamIndividualBindingAutoStartup() throws Exception { + void kstreamIndividualBindingAutoStartup() throws Exception { SpringApplication app = new SpringApplication(WordCountProcessorApplication.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -283,7 +283,7 @@ class KafkaStreamsBinderWordCountFunctionTests { // The following test verifies the fixes made for this issue: // https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/774 @Test - void testOutboundNullValueIsHandledGracefully() + void outboundNullValueIsHandledGracefully() throws Exception { SpringApplication app = new SpringApplication(OutboundNullApplication.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsComponentBeansTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsComponentBeansTests.java index 851fbc717..86c7e6207 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsComponentBeansTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsComponentBeansTests.java @@ -101,7 +101,7 @@ class KafkaStreamsComponentBeansTests { } @Test - void testFunctionComponent() { + void functionComponent() { SpringApplication app = new SpringApplication(FunctionAsComponent.class); app.setWebApplicationType(WebApplicationType.NONE); try (ConfigurableApplicationContext ignored = app.run( @@ -127,7 +127,7 @@ class KafkaStreamsComponentBeansTests { } @Test - void testConsumerComponent() throws Exception { + void consumerComponent() throws Exception { SpringApplication app = new SpringApplication(ConsumerAsComponent.class); app.setWebApplicationType(WebApplicationType.NONE); try (ConfigurableApplicationContext context = app.run( @@ -151,7 +151,7 @@ class KafkaStreamsComponentBeansTests { } @Test - void testBiFunctionComponent() { + void biFunctionComponent() { SpringApplication app = new SpringApplication(BiFunctionAsComponent.class); app.setWebApplicationType(WebApplicationType.NONE); try (ConfigurableApplicationContext ignored = app.run( @@ -181,7 +181,7 @@ class KafkaStreamsComponentBeansTests { } @Test - void testBiConsumerComponent() throws Exception { + void biConsumerComponent() throws Exception { SpringApplication app = new SpringApplication(BiConsumerAsComponent.class); app.setWebApplicationType(WebApplicationType.NONE); try (ConfigurableApplicationContext context = app.run( @@ -208,7 +208,7 @@ class KafkaStreamsComponentBeansTests { } @Test - void testCurriedFunctionWithConsumerTerminal() throws Exception { + void curriedFunctionWithConsumerTerminal() throws Exception { SpringApplication app = new SpringApplication(CurriedFunctionWithConsumerTerminal.class); app.setWebApplicationType(WebApplicationType.NONE); try (ConfigurableApplicationContext context = app.run( @@ -238,7 +238,7 @@ class KafkaStreamsComponentBeansTests { } @Test - void testCurriedFunctionWithFunctionTerminal() { + void curriedFunctionWithFunctionTerminal() { SpringApplication app = new SpringApplication(CurriedFunctionWithFunctionTerminal.class); app.setWebApplicationType(WebApplicationType.NONE); try (ConfigurableApplicationContext context = app.run( diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionStateStoreTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionStateStoreTests.java index b51d566c6..2c8935b3e 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionStateStoreTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionStateStoreTests.java @@ -51,7 +51,7 @@ class KafkaStreamsFunctionStateStoreTests { private static final EmbeddedKafkaBroker embeddedKafka = EmbeddedKafkaCondition.getBroker(); @Test - void testKafkaStreamsFuncionWithMultipleStateStores() throws Exception { + void kafkaStreamsFuncionWithMultipleStateStores() throws Exception { SpringApplication app = new SpringApplication(StateStoreTestApplication.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsRetryTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsRetryTests.java index f406e0db2..a7836fbb1 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsRetryTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsRetryTests.java @@ -61,7 +61,7 @@ class KafkaStreamsRetryTests { private final static CountDownLatch LATCH2 = new CountDownLatch(4); @Test - void testRetryTemplatePerBindingOnKStream() throws Exception { + void retryTemplatePerBindingOnKStream() throws Exception { SpringApplication app = new SpringApplication(RetryTemplatePerConsumerBindingApp.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -83,7 +83,7 @@ class KafkaStreamsRetryTests { } @Test - void testRetryTemplateOnTableTypes() throws Exception { + void retryTemplateOnTableTypes() throws Exception { SpringApplication app = new SpringApplication(RetryTemplatePerConsumerBindingApp.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -100,7 +100,7 @@ class KafkaStreamsRetryTests { } @Test - void testRetryTemplateBeanProvidedByTheApp() throws Exception { + void retryTemplateBeanProvidedByTheApp() throws Exception { SpringApplication app = new SpringApplication(CustomRetryTemplateApp.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToGlobalKTableFunctionTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToGlobalKTableFunctionTests.java index 861dd92ae..0cf1265b7 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToGlobalKTableFunctionTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToGlobalKTableFunctionTests.java @@ -70,7 +70,7 @@ class StreamToGlobalKTableFunctionTests { private static Consumer consumer; @Test - void testStreamToGlobalKTable() throws Exception { + void streamToGlobalKTable() throws Exception { SpringApplication app = new SpringApplication(OrderEnricherApplication.class); app.setWebApplicationType(WebApplicationType.NONE); try (ConfigurableApplicationContext context = app.run("--server.port=0", @@ -222,7 +222,7 @@ class StreamToGlobalKTableFunctionTests { } @Test - void testTimeExtractor() throws Exception { + void timeExtractor() throws Exception { SpringApplication app = new SpringApplication(OrderEnricherApplication.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToTableJoinFunctionTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToTableJoinFunctionTests.java index 1714de1c5..5c8186e96 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToTableJoinFunctionTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/StreamToTableJoinFunctionTests.java @@ -78,7 +78,7 @@ class StreamToTableJoinFunctionTests { private static final EmbeddedKafkaBroker embeddedKafka = EmbeddedKafkaCondition.getBroker(); @Test - void testStreamToTable() { + void streamToTable() { SpringApplication app = new SpringApplication(CountClicksPerRegionApplication.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -96,7 +96,7 @@ class StreamToTableJoinFunctionTests { } @Test - void testStreamToTableBiFunction() { + void streamToTableBiFunction() { SpringApplication app = new SpringApplication(BiFunctionCountClicksPerRegionApplication.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -114,7 +114,7 @@ class StreamToTableJoinFunctionTests { } @Test - void testStreamToTableBiConsumer() throws Exception { + void streamToTableBiConsumer() throws Exception { SpringApplication app = new SpringApplication(BiConsumerApplication.class); app.setWebApplicationType(WebApplicationType.NONE); @@ -433,7 +433,7 @@ class StreamToTableJoinFunctionTests { } @Test - public void testTrivialSingleKTableInputAsNonDeclarative() { + public void trivialSingleKTableInputAsNonDeclarative() { SpringApplication app = new SpringApplication(TrivialKTableApp.class); app.setWebApplicationType(WebApplicationType.NONE); app.run("--server.port=0", @@ -446,7 +446,7 @@ class StreamToTableJoinFunctionTests { } @Test - public void testTwoKStreamsCanBeJoined() { + public void twoKStreamsCanBeJoined() { SpringApplication app = new SpringApplication( JoinProcessor.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DlqDestinationResolverTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DlqDestinationResolverTests.java index 2c1c47b87..654ee641b 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DlqDestinationResolverTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DlqDestinationResolverTests.java @@ -59,7 +59,7 @@ class DlqDestinationResolverTests { private static final EmbeddedKafkaBroker embeddedKafka = EmbeddedKafkaCondition.getBroker(); @Test - void testDlqDestinationResolverWorks() throws Exception { + void dlqDestinationResolverWorks() throws Exception { SpringApplication app = new SpringApplication(WordCountProcessorApplication.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DltAwareProcessorTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DltAwareProcessorTests.java index f069f9994..4229c3c7f 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DltAwareProcessorTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/DltAwareProcessorTests.java @@ -74,7 +74,7 @@ class DltAwareProcessorTests { } @Test - void testDltAwareProcessor() { + void dltAwareProcessor() { SpringApplication app = new SpringApplication( DltAwareProcessorTests.PublishToDltOnErrorApplication.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderDestinationIsPatternTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderDestinationIsPatternTests.java index 9f961ed4e..63ed15071 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderDestinationIsPatternTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderDestinationIsPatternTests.java @@ -66,7 +66,7 @@ class KafkaStreamsBinderDestinationIsPatternTests { } @Test - void test() { + void destinationIsPattern() { SpringApplication app = new SpringApplication(ConsumingApplication.class); app.setWebApplicationType(WebApplicationType.NONE); ConfigurableApplicationContext context = app.run("--server.port=0", diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderMultipleInputTopicsTest.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderMultipleInputTopicsTest.java index eb8a9e8fd..c4c70c8e0 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderMultipleInputTopicsTest.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderMultipleInputTopicsTest.java @@ -85,7 +85,7 @@ class KafkaStreamsBinderMultipleInputTopicsTest { } @Test - void testKstreamWordCountWithStringInputAndPojoOuput() throws Exception { + void kstreamWordCountWithStringInputAndPojoOuput() throws Exception { SpringApplication app = new SpringApplication( WordCountProcessorApplication.class); app.setWebApplicationType(WebApplicationType.NONE); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests.java index 3619b1373..6860cdab9 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests.java @@ -78,7 +78,7 @@ class KafkaStreamsBinderPojoInputAndPrimitiveTypeOutputTests { } @Test - void testKstreamBinderWithPojoInputAndStringOuput() throws Exception { + void kstreamBinderWithPojoInputAndStringOuput() throws Exception { SpringApplication app = new SpringApplication(ProductCountApplication.class); app.setWebApplicationType(WebApplicationType.NONE); ConfigurableApplicationContext context = app.run("--server.port=0", diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderTombstoneTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderTombstoneTests.java index 9cac3e0fd..f773dae99 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderTombstoneTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsBinderTombstoneTests.java @@ -86,7 +86,7 @@ class KafkaStreamsBinderTombstoneTests { } @Test - void testSendToTombstone() + void sendToTombstone() throws Exception { SpringApplication app = new SpringApplication( WordCountProcessorApplication.class); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsNativeEncodingDecodingTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsNativeEncodingDecodingTests.java index 3b56adc5a..d17bea46c 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsNativeEncodingDecodingTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsNativeEncodingDecodingTests.java @@ -116,7 +116,7 @@ public abstract class KafkaStreamsNativeEncodingDecodingTests { extends KafkaStreamsNativeEncodingDecodingTests { @Test - public void test() throws Exception { + public void nativeEncodingDecodingEnabled() throws Exception { Map senderProps = KafkaTestUtils.producerProps(embeddedKafka); DefaultKafkaProducerFactory pf = new DefaultKafkaProducerFactory<>( senderProps); @@ -146,7 +146,7 @@ public abstract class KafkaStreamsNativeEncodingDecodingTests { extends KafkaStreamsNativeEncodingDecodingTests { @Test - public void test() { + public void nativeEncodingDecodingDisabled() { Map senderProps = KafkaTestUtils.producerProps(embeddedKafka); DefaultKafkaProducerFactory pf = new DefaultKafkaProducerFactory<>( senderProps); diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsStateStoreIntegrationTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsStateStoreIntegrationTests.java index 7be5c6d96..c2ee15456 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsStateStoreIntegrationTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkaStreamsStateStoreIntegrationTests.java @@ -84,7 +84,7 @@ class KafkaStreamsStateStoreIntegrationTests { } @Test - void testSameStateStoreIsCreatedOnlyOnceWhenMultipleInputBindingsArePresent() throws Exception { + void sameStateStoreIsCreatedOnlyOnceWhenMultipleInputBindingsArePresent() throws Exception { SpringApplication app = new SpringApplication(ProductCountApplicationWithMultipleInputBindings.class); app.setWebApplicationType(WebApplicationType.NONE); ConfigurableApplicationContext context = app.run("--server.port=0", diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkastreamsBinderPojoInputStringOutputIntegrationTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkastreamsBinderPojoInputStringOutputIntegrationTests.java index 77c09ee0b..fe74ff206 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkastreamsBinderPojoInputStringOutputIntegrationTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/KafkastreamsBinderPojoInputStringOutputIntegrationTests.java @@ -80,7 +80,7 @@ class KafkastreamsBinderPojoInputStringOutputIntegrationTests { } @Test - void testKstreamBinderWithPojoInputAndStringOuput() throws Exception { + void kstreamBinderWithPojoInputAndStringOuput() throws Exception { SpringApplication app = new SpringApplication(ProductCountApplication.class); app.setWebApplicationType(WebApplicationType.NONE); ConfigurableApplicationContext context = app.run("--server.port=0", diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerdeTest.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerdeTest.java index b0e17f987..929855c1d 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerdeTest.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerdeTest.java @@ -32,7 +32,7 @@ import static org.assertj.core.api.Assertions.assertThat; class CollectionSerdeTest { @Test - public void testCollectionsSerde() { + public void collectionsSerde() { Foo foo1 = new Foo(); foo1.setData("data-1");