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

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

diff --cc docker-compose.yml
index 5723fc7ebd0ce45ad154be632cae4e64b44f492c,1b067cdeb1f29ddff4ea4023bc038c5c82cb6b1a..e30a7bb0341ec483c06a621d0954654fab3b3ac9
--- 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 78b2fde4ee0d17444c93dd455d1d64442730bc5b,9db9d9d07623fb7a53283b356e1ce636e32e2cd6..0fbe7e64b21a72d78552c4cb1033b6fc320ce291
--- 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 bcbf41848038e4754f0bb729a98d9d3b6ff8592e,de4b66d74cdbe0393dddee826fb05201032c1ff1..2f6e4f2db57c9c0d587f7c1f5185a6b606f5d7d2
--- 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 94490a3f5df967b432653019ca9c9aed4747637a,9f3cb81bb6690d90e92da28273d6a5954041ec0e..93b27c201cfa5990b4c6677f47e01194d204e03e
--- 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