update link + added test properties

Author: code-not-found

spring-kafka-batch-listener/README.md

@@ -4,4 +4,4 @@
 
 A detailed step-by-step tutorial on how to implement a Spring Kafka Batch Listener using Spring Boot.
 
-[https://www.codenotfound.com/2017/04/spring-kafka-batch-listener-example.html](https://www.codenotfound.com/2017/04/spring-kafka-batch-listener-example.html)
+[https://www.codenotfound.com/spring-kafka-batch-listener-example.html](https://www.codenotfound.com/spring-kafka-batch-listener-example.html)

spring-kafka-batch-listener/pom.xml

@@ -9,7 +9,7 @@
 
   <name>spring-kafka-batch-listener</name>
   <description>Spring Kafka - Batch Listener Example</description>
-  <url>https://www.codenotfound.com/2017/04/spring-kafka-batch-listener-example.html</url>
+  <url>https://www.codenotfound.com/spring-kafka-batch-listener-example.html</url>
 
   <parent>
     <groupId>org.springframework.boot</groupId>

spring-kafka-batch-listener/src/main/java/com/codenotfound/kafka/consumer/Receiver.java

@@ -21,11 +21,10 @@ public CountDownLatch getLatch() {
     return latch;
   }
 
-  @KafkaListener(id = "batch-listener", topics = "${topic.batch}")
+  @KafkaListener(id = "batch-listener", topics = "${kafka.topic.batch}")
   public void receive(List<String> data,
       @Header(KafkaHeaders.RECEIVED_PARTITION_ID) List<Integer> partitions,
       @Header(KafkaHeaders.OFFSET) List<Long> offsets) {
-
     LOGGER.info("start of batch receive");
     for (int i = 0; i < data.size(); i++) {
       LOGGER.info("received message='{}' with partition-offset='{}'", data.get(i),

spring-kafka-batch-listener/src/main/java/com/codenotfound/kafka/consumer/ReceiverConfig.java

@@ -23,7 +23,6 @@ public class ReceiverConfig {
   @Bean
   public Map<String, Object> consumerConfigs() {
     Map<String, Object> props = new HashMap<>();
-
     props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
     props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
     props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);

spring-kafka-batch-listener/src/main/java/com/codenotfound/kafka/producer/SenderConfig.java

@@ -21,7 +21,6 @@ public class SenderConfig {
   @Bean
   public Map<String, Object> producerConfigs() {
     Map<String, Object> props = new HashMap<>();
-
     props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
     props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
     props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);

spring-kafka-batch-listener/src/main/resources/application.yml

@@ -1,5 +1,4 @@
 kafka:
   bootstrap-servers: localhost:9092
-
-topic:
-  batch: batch.t
+  topic:
+    batch: batch.t

spring-kafka-batch-listener/src/main/resources/logback.xml

@@ -10,7 +10,6 @@
   <logger name="com.codenotfound" level="INFO" />
   <logger name="org.springframework" level="WARN" />
 
-
   <root level="WARN">
     <appender-ref ref="STDOUT" />
   </root>

spring-kafka-batch-listener/src/test/java/com/codenotfound/kafka/SpringKafkaApplicationTest.java

@@ -5,7 +5,6 @@
 import java.util.concurrent.TimeUnit;
 
 import org.junit.Before;
-import org.junit.BeforeClass;
 import org.junit.ClassRule;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -38,11 +37,6 @@ public class SpringKafkaApplicationTest {
   @ClassRule
   public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true, BATCH_TOPIC);
 
-  @BeforeClass
-  public static void setUpBeforeClass() {
-    System.setProperty("kafka.bootstrap-servers", embeddedKafka.getBrokersAsString());
-  }
-
   @Before
   public void setUp() throws Exception {
     // wait until the partitions are assigned

spring-kafka-batch-listener/src/test/resources/application.yml

@@ -0,0 +1,4 @@
+kafka:
+  bootstrap-servers: ${spring.embedded.kafka.brokers}
+  topic:
+    batch: batch.t