From: Kai Moritz <kai@juplo.de>
Date: Sat, 23 Jul 2022 10:13:05 +0000 (+0200)
Subject: Merge der überarbeiteten Compose-Konfiguration ('endless-stream-producer')
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=refs%2Fheads%2Fsetup-partitionierung;hp=ed2942b74c61f6e0a99747c87813900ed666f860;p=demos%2Fkafka%2Ftraining

Merge der überarbeiteten Compose-Konfiguration ('endless-stream-producer')
---

diff --git a/docker-compose.yml b/docker-compose.yml
index 023bfdd..de99240 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -41,6 +41,7 @@ services:
     ports:
       - 8000:8080
     environment:
+      server.port: 8080
       producer.bootstrap-server: kafka:9092
       producer.client-id: producer
       producer.topic: test
@@ -50,8 +51,9 @@ services:
   consumer:
     image: juplo/counting-consumer:1.0-SNAPSHOT
     ports:
-      - 8081:8081
+      - 8081:8080
     environment:
+      server.port: 8080
       consumer.bootstrap-server: kafka:9092
       consumer.client-id: my-group
       consumer.client-id: consumer
diff --git a/pom.xml b/pom.xml
index e7ad998..af4a89f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -50,6 +50,17 @@
       <plugin>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-maven-plugin</artifactId>
+        <executions>
+          <execution>
+            <goals>
+              <goal>build-info</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+      <plugin>
+        <groupId>pl.project13.maven</groupId>
+        <artifactId>git-commit-id-plugin</artifactId>
       </plugin>
       <plugin>
         <groupId>io.fabric8</groupId>
diff --git a/src/main/java/de/juplo/kafka/DriverController.java b/src/main/java/de/juplo/kafka/DriverController.java
index b3af107..ce4df68 100644
--- a/src/main/java/de/juplo/kafka/DriverController.java
+++ b/src/main/java/de/juplo/kafka/DriverController.java
@@ -1,8 +1,10 @@
 package de.juplo.kafka;
 
 import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpStatus;
 import org.springframework.web.bind.annotation.ExceptionHandler;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.ResponseStatus;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.concurrent.ExecutionException;
@@ -28,8 +30,9 @@ public class DriverController
   }
 
   @ExceptionHandler
+  @ResponseStatus(HttpStatus.BAD_REQUEST)
   public ErrorResponse illegalStateException(IllegalStateException e)
   {
-    return new ErrorResponse(e.getMessage(), 400);
+    return new ErrorResponse(e.getMessage(), HttpStatus.BAD_REQUEST.value());
   }
 }
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index e4ae52a..7dd385b 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -1,15 +1,32 @@
 producer:
   bootstrap-server: :9092
-  client-id: peter
+  client-id: DEV
   topic: test
   acks: 1
   throttle-ms: 1000
 management:
+  endpoint:
+    shutdown:
+      enabled: true
   endpoints:
     web:
       exposure:
         include: "*"
+  info:
+    env:
+      enabled: true
+    java:
+      enabled: true
+info:
+  kafka:
+    bootstrap-server: ${producer.bootstrap-server}
+    client-id: ${producer.client-id}
+    topic: ${producer.topic}
+    acks: ${producer.acks}
+    throttle-ms: ${producer.throttle-ms}
 logging:
   level:
     root: INFO
     de.juplo: DEBUG
+server:
+  port: 8880