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

* Dabei auch die letzten Verbesserungen aus 'rebalance-listener' übernommen.

diff --cc docker-compose.yml
index 5723fc7,1b067cd..e30a7bb
--- 1/docker-compose.yml
--- 2/docker-compose.yml
+++ b/docker-compose.yml
@@@ -67,10 -51,10 +68,11 @@@ services
    consumer:
      image: juplo/endless-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
        consumer.topic: test
 +      spring.data.mongodb.uri: mongodb://juplo:training@mongo:27017
 +      spring.data.mongodb.database: juplo

diff --cc pom.xml
index 78b2fde,9db9d9d..0fbe7e6
--- 1/pom.xml
--- 2/pom.xml
+++ b/pom.xml
@@@ -21,10 -21,10 +21,14 @@@
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
      </dependency>
 +    <dependency>
 +      <groupId>org.springframework.boot</groupId>
 +      <artifactId>spring-boot-starter-data-mongodb</artifactId>
 +    </dependency>
+     <dependency>
+       <groupId>org.springframework.boot</groupId>
+       <artifactId>spring-boot-starter-validation</artifactId>
+     </dependency>
      <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>

diff --cc src/main/java/de/juplo/kafka/Application.java
index bcbf418,de4b66d..2f6e4f2
--- 1/src/main/java/de/juplo/kafka/Application.java
--- 2/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@@ -19,13 -18,8 +18,8 @@@ public class Applicatio
  
  
    @Bean
 -  public EndlessConsumer consumer()
 +  public EndlessConsumer consumer(PartitionStatisticsRepository repository)
    {
-     Assert.hasText(properties.getBootstrapServer(), "consumer.bootstrap-server must be set");
-     Assert.hasText(properties.getGroupId(), "consumer.group-id must be set");
-     Assert.hasText(properties.getClientId(), "consumer.client-id must be set");
-     Assert.hasText(properties.getTopic(), "consumer.topic must be set");
- 
      EndlessConsumer consumer =
          new EndlessConsumer(
              Executors.newFixedThreadPool(1),

diff --cc src/main/java/de/juplo/kafka/EndlessConsumer.java
Simple merge

diff --cc src/main/resources/application.yml
index 94490a3,9f3cb81..93b27c2
--- 1/src/main/resources/application.yml
--- 2/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@@ -9,11 -12,18 +12,23 @@@ management
      web:
        exposure:
          include: "*"
+   info:
+     env:
+       enabled: true
+     java:
+       enabled: true
+ info:
+   kafka:
+     bootstrap-server: ${consumer.bootstrap-server}
+     client-id: ${consumer.client-id}
+     group-id: ${consumer.group-id}
+     topic: ${consumer.topic}
+     auto-offset-reset: ${consumer.auto-offset-reset}
 +spring:
 +  data:
 +    mongodb:
 +      uri: mongodb://juplo:training@localhost:27017
 +      database: juplo
  logging:
    level:
      root: INFO