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 04dc343..be152fa 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 9a237b7..a31c256 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 a76132b..dd43b11 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;