Merge der überarbeiteten Compose-Konfiguration ('deserialization') springify-experiments
authorKai Moritz <kai@juplo.de>
Sat, 23 Jul 2022 14:25:02 +0000 (16:25 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 23 Jul 2022 14:25:02 +0000 (16:25 +0200)
1  2 
docker-compose.yml
pom.xml
src/main/java/de/juplo/kafka/DriverController.java

@@@ -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
  
  
    consumer:
 -    image: juplo/endless-consumer:1.0-SNAPSHOT
 +    image: juplo/springified-consumer:1.0-SNAPSHOT
      ports:
-       - 8081:8881
+       - 8081:8080
      environment:
 -      consumer.bootstrap-server: kafka:9092
 -      consumer.client-id: my-group
 -      consumer.client-id: consumer
+       server.port: 8080
 +      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 pom.xml
Simple merge
@@@ -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)