diff --git a/spring-kafka-3/src/main/java/com/baeldung/spring/kafka/groupId/KafkaConfig.java b/spring-kafka-3/src/main/java/com/baeldung/spring/kafka/groupId/KafkaConfig.java index b8d7c42ec9..6514816424 100644 --- a/spring-kafka-3/src/main/java/com/baeldung/spring/kafka/groupId/KafkaConfig.java +++ b/spring-kafka-3/src/main/java/com/baeldung/spring/kafka/groupId/KafkaConfig.java @@ -44,4 +44,4 @@ class KafkaConfig { return new KafkaErrorHandler(); } -} \ No newline at end of file +} diff --git a/spring-kafka-3/src/main/java/com/baeldung/spring/kafka/groupId/KafkaErrorHandler.java b/spring-kafka-3/src/main/java/com/baeldung/spring/kafka/groupId/KafkaErrorHandler.java index a30254ea47..00cc795272 100644 --- a/spring-kafka-3/src/main/java/com/baeldung/spring/kafka/groupId/KafkaErrorHandler.java +++ b/spring-kafka-3/src/main/java/com/baeldung/spring/kafka/groupId/KafkaErrorHandler.java @@ -34,4 +34,4 @@ class KafkaErrorHandler implements CommonErrorHandler { log.error("Exception not handled", exception); } } -} \ No newline at end of file +} diff --git a/spring-kafka-3/src/test/java/com/baeldung/spring/kafka/groupId/MainLiveTest.java b/spring-kafka-3/src/test/java/com/baeldung/spring/kafka/groupId/MainLiveTest.java index 97b056db73..c7e78f6e58 100644 --- a/spring-kafka-3/src/test/java/com/baeldung/spring/kafka/groupId/MainLiveTest.java +++ b/spring-kafka-3/src/test/java/com/baeldung/spring/kafka/groupId/MainLiveTest.java @@ -41,4 +41,4 @@ public class MainLiveTest { assertTrue(messageConsumed); assertThat(consumer.getPayload(), containsString(data)); } -} \ No newline at end of file +}