From: Kai Moritz <kai@juplo.de>
Date: Sat, 23 Jul 2022 14:25:02 +0000 (+0200)
Subject: Merge der überarbeiteten Compose-Konfiguration ('deserialization')
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=refs%2Fheads%2Fspringify-experiments;p=demos%2Fkafka%2Ftraining

Merge der überarbeiteten Compose-Konfiguration ('deserialization')
---

24d7ee1e7e33b6748bef018931076ad3f8e9a61b
diff --cc docker-compose.yml
index 0364de4,159f9cb..308afc4
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@@ -39,10 -37,11 +39,11 @@@ services
      command: sleep infinity
  
    producer:
 -    image: juplo/endless-producer:1.0-SNAPSHOT
 +    image: juplo/springified-producer:1.0-SNAPSHOT
      ports:
-       - 8080:8880
+       - 8080:8080
      environment:
+       server.port: 8080
        producer.bootstrap-server: kafka:9092
        producer.client-id: producer
        producer.topic: test
@@@ -50,13 -49,12 +51,14 @@@
  
  
    consumer:
 -    image: juplo/endless-consumer:1.0-SNAPSHOT
 +    image: juplo/springified-consumer:1.0-SNAPSHOT
      ports:
-       - 8081:8881
+       - 8081:8080
      environment:
+       server.port: 8080
 -      consumer.bootstrap-server: kafka:9092
 -      consumer.client-id: my-group
 -      consumer.client-id: consumer
 +      spring.kafka.consumer.bootstrap-servers: kafka:9092
 +      spring.kafka.consumer.group-id: my-group
 +      spring.kafka.consumer.client-id: consumer
 +      spring.kafka.producer.bootstrap-servers: kafka:9092
 +      spring.kafka.producer.client-id: consumer
        consumer.topic: test
diff --cc src/main/java/de/juplo/kafka/DriverController.java
index 8bc3115,ed38080..87e8e58
--- a/src/main/java/de/juplo/kafka/DriverController.java
+++ b/src/main/java/de/juplo/kafka/DriverController.java
@@@ -34,9 -35,10 +35,10 @@@ public class DriverControlle
    @GetMapping("seen")
    public Map<Integer, Map<String, Long>> seen()
    {
 -    return consumer.getSeen();
 +    return new HashMap<>();
    }
  
+ 
    @ExceptionHandler
    @ResponseStatus(HttpStatus.BAD_REQUEST)
    public ErrorResponse illegalStateException(IllegalStateException e)