Merge der überarbeiteten Compose-Konfiguration ('rebalance-listener')

diff --combined docker-compose.yml
index b03bb1e,1b067cd..159f9cb
--- 1/docker-compose.yml
--- 2/docker-compose.yml
+++ b/docker-compose.yml
@@@ -1,14 -1,14 +1,14 @@@
  version: '3.2'
  services:
    zookeeper:
-     image: confluentinc/cp-zookeeper:7.0.2
+     image: confluentinc/cp-zookeeper:7.1.3
      environment:
        ZOOKEEPER_CLIENT_PORT: 2181
      ports:
        - 2181:2181
  
    kafka:
-     image: confluentinc/cp-kafka:7.0.2
+     image: confluentinc/cp-kafka:7.1.3
      environment:
        KAFKA_BROKER_ID: 1
        KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
@@@ -24,13 -24,13 +24,13 @@@
      depends_on:
        - zookeeper
  
 -  kafka-ui:
 -    image: provectuslabs/kafka-ui:0.3.3
 -    ports:
 -      - 8080:8080
 -    environment:
 -      KAFKA_CLUSTERS_0_NAME: local
 -      KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: kafka:9092
 +  setup:
 +    image: juplo/toolbox
 +    command: >
 +      bash -c "
 +        kafka-topics --bootstrap-server kafka:9092 --delete --if-exists --topic test
 +        kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 2
 +      "
  
    cli:
      image: juplo/toolbox
@@@ -39,19 -39,21 +39,21 @@@
    producer:
      image: juplo/endless-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
 -      producer.throttle-ms: 10
 +      producer.throttle-ms: 200
  
  
    consumer:
      image: juplo/endless-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

diff --combined pom.xml
index f218085,9db9d9d..1f5caab
--- 1/pom.xml
--- 2/pom.xml
+++ b/pom.xml
@@@ -7,7 -7,7 +7,7 @@@
    <parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
-     <version>2.6.5</version>
+     <version>2.7.2</version>
      <relativePath/> <!-- lookup parent from repository -->
    </parent>
  
@@@ -47,16 -47,6 +47,16 @@@
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
      </dependency>
 +    <dependency>
 +      <groupId>org.springframework.kafka</groupId>
 +      <artifactId>spring-kafka-test</artifactId>
 +      <scope>test</scope>
 +    </dependency>
 +    <dependency>
 +      <groupId>org.awaitility</groupId>
 +      <artifactId>awaitility</artifactId>
 +      <scope>test</scope>
 +    </dependency>
    </dependencies>
  
    <build>

diff --combined src/main/java/de/juplo/kafka/DriverController.java
index 93580ee,1fb2a1b..ed38080
--- 1/src/main/java/de/juplo/kafka/DriverController.java
--- 2/src/main/java/de/juplo/kafka/DriverController.java
+++ b/src/main/java/de/juplo/kafka/DriverController.java
@@@ -31,12 -31,14 +31,14 @@@ public class DriverControlle
      consumer.stop();
    }
  
+ 
    @GetMapping("seen")
 -  public Map<Integer, Map<String, Integer>> seen()
 +  public Map<Integer, Map<String, Long>> seen()
    {
      return consumer.getSeen();
    }
  
+ 
    @ExceptionHandler
    @ResponseStatus(HttpStatus.BAD_REQUEST)
    public ErrorResponse illegalStateException(IllegalStateException e)