Einheitliche Benennung des Consumers -- ALIGN

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index 04dc343c490d68fa634f071946573e5e17fd833b..be152fab31e24357c218b3463f4c30cce3a7e7b2 100644 (file)
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -24,7 +24,7 @@ public class Application implements ApplicationRunner
   @Autowired
   Consumer<?, ?> kafkaConsumer;
   @Autowired
-  SimpleConsumer simpleConsumer;
+  ExampleConsumer exampleConsumer;
   @Autowired
   ConfigurableApplicationContext context;
 
@@ -33,17 +33,17 @@ public class Application implements ApplicationRunner
   @Override
   public void run(ApplicationArguments args) throws Exception
   {
-    log.info("Starting SimpleConsumer");
-    consumerJob = taskExecutor.submitListenable(simpleConsumer);
+    log.info("Starting ExampleConsumer");
+    consumerJob = taskExecutor.submitListenable(exampleConsumer);
     consumerJob.addCallback(
       exitStatus ->
       {
-        log.info("SimpleConsumer exited normally, exit-status: {}", exitStatus);
+        log.info("ExampleConsumer exited normally, exit-status: {}", exitStatus);
         SpringApplication.exit(context, () -> exitStatus);
         },
       t ->
       {
-        log.error("SimpleConsumer exited abnormally!", t);
+        log.error("ExampleConsumer exited abnormally!", t);
         SpringApplication.exit(context, () -> 2);
       });
   }
@@ -51,11 +51,11 @@ public class Application implements ApplicationRunner
   @PreDestroy
   public void shutdown() throws ExecutionException, InterruptedException
   {
-    log.info("Signaling SimpleConsumer to quit its work");
+    log.info("Signaling ExampleConsumer to quit its work");
     kafkaConsumer.wakeup();
-    log.info("Waiting for SimpleConsumer to finish its work");
+    log.info("Waiting for ExampleConsumer to finish its work");
     consumerJob.get();
-    log.info("SimpleConsumer finished its work");
+    log.info("ExampleConsumer finished its work");
   }
 
 

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 9a237b77e24a4b58b0bebc9faf8c9de9caac3264..a31c25624e153e6a6cfce4be965cd98b12c95540 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -14,13 +14,13 @@ import org.springframework.kafka.core.ConsumerFactory;
 public class ApplicationConfiguration
 {
   @Bean
-  public SimpleConsumer simpleConsumer(
+  public ExampleConsumer exampleConsumer(
       Consumer<String, String> kafkaConsumer,
       KafkaProperties kafkaProperties,
       ApplicationProperties applicationProperties)
   {
     return
-        new SimpleConsumer(
+        new ExampleConsumer(
             kafkaProperties.getClientId(),
             applicationProperties.getTopics(),
             kafkaConsumer);

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index a76132b17c278609d5c05dec472b909d17345e45..dd43b112c21f71b8eb83abf27aa168e0e2c2bc37 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -14,7 +14,7 @@ import java.util.concurrent.Callable;
 
 @Slf4j
 @RequiredArgsConstructor
-public class SimpleConsumer implements Callable<Integer>
+public class ExampleConsumer implements Callable<Integer>
 {
   private final String id;
   private final String[] topics;