Anpassungen des Projekts/Setups aus 'simple-producer' übernommen

diff --combined Dockerfile
index 0000000,ea4d335..3aefb4b
mode 000000,100644..100644
--- /dev/null
--- 2/Dockerfile
+++ b/Dockerfile
@@@ -1,0 -1,6 +1,6 @@@
 -COPY target/dependency /opt/libs
 -ENTRYPOINT [ "java", "-jar", "/opt/app.jar", "kafka:9092", "test" ]
+ FROM openjdk:11-jre
+ VOLUME /tmp
+ COPY target/*.jar /opt/app.jar
++COPY target/libs /opt/libs
++ENTRYPOINT [ "java", "-jar", "/opt/app.jar", "kafka:9092", "test", "my-group" ]
+ CMD [ "DCKR" ]

diff --combined README.sh
index 0ee50a9,3f46c04..b1ba0be
--- 1/README.sh
--- 2/README.sh
+++ b/README.sh
@@@ -1,5 -1,7 +1,7 @@@
  #!/bin/bash
  
 -IMAGE=juplo/simple-producer:1.0-SNAPSHOT
++IMAGE=juplo/simple-consumer:1.0-SNAPSHOT
+ 
  if [ "$1" = "cleanup" ]
  then
    docker-compose down -v
@@@ -7,27 -9,27 +9,28 @@@
    exit
  fi
  
- mvn package || exit 1
- if [ "$1" = "build" ]; then exit; fi
- 
- trap 'kill $(jobs -p) 2>/dev/null' EXIT
+ docker-compose up -d zookeeper kafka-1 kafka-2 kafka-3 cli
  
- docker-compose up -d
+ if [[
+   $(docker image ls -q $IMAGE) == "" ||
+   "$1" = "build"
+ ]]
+ then
+   mvn install || exit
+ else
+   echo "Using image existing images:"
+   docker image ls $IMAGE
+ fi
  
  echo "Waiting for the Kafka-Cluster to become ready..."
  docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
+ docker-compose up setup
+ docker-compose up -d
+ sleep 5
  
- echo "Producing messages"
- mvn exec:java@producer
- 
- echo "Reading messages"
- mvn exec:java@consumer &
- sleep 7
- kill $(jobs -p)
- sleep 2
+ docker-compose exec cli kafkacat -b kafka:9092 -t test -q -c 20 -f'topic=%t\tpartition=%p\toffset=%o\tkey=%k\tvalue=%s\n'
  
- echo "Re-Reading messages"
- mvn exec:java@consumer &
- sleep 7
- kill $(jobs -p)
- sleep 2
 -docker-compose stop producer
 -docker-compose exec cli kafkacat -b kafka:9092 -t test -q -e -f'topic=%t\tpartition=%p\toffset=%o\tkey=%k\tvalue=%s\n'
 -docker-compose logs producer
++docker-compose stop producer consumer-1 consumer-2 consumer-3
++docker-compose logs consumer-1
++docker-compose logs consumer-2
++docker-compose logs consumer-3

diff --combined docker-compose.yml
index ec307f5,d9f15c8..6ab0d1b
--- 1/docker-compose.yml
--- 2/docker-compose.yml
+++ b/docker-compose.yml
@@@ -7,20 -7,56 +7,56 @@@ services
      ports:
        - 2181:2181
  
-   kafka:
+   kafka-1:
      image: confluentinc/cp-kafka:7.1.3
      environment:
        KAFKA_BROKER_ID: 1
        KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+       KAFKA_LISTENERS: DOCKER://:9092, LOCALHOST://:9081
+       KAFKA_ADVERTISED_LISTENERS: DOCKER://kafka-1:9092, LOCALHOST://localhost:9081
+       KAFKA_INTER_BROKER_LISTENER_NAME: DOCKER
+       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: DOCKER:PLAINTEXT, LOCALHOST:PLAINTEXT
+       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3
+       KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
+     ports:
+       - 9081:9081
+     depends_on:
+       - zookeeper
+ 
+   kafka-2:
+     image: confluentinc/cp-kafka:7.1.3
+     environment:
+       KAFKA_BROKER_ID: 2
+       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
        KAFKA_LISTENERS: DOCKER://:9092, LOCALHOST://:9082
-       KAFKA_ADVERTISED_LISTENERS: DOCKER://kafka:9092, LOCALHOST://localhost:9082
+       KAFKA_ADVERTISED_LISTENERS: DOCKER://kafka-2:9092, LOCALHOST://localhost:9082
        KAFKA_INTER_BROKER_LISTENER_NAME: DOCKER
        KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: DOCKER:PLAINTEXT, LOCALHOST:PLAINTEXT
-       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3
        KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
      ports:
        - 9092:9082
        - 9082:9082
+     networks:
+       default:
+         aliases:
+           - kafka
+     depends_on:
+       - zookeeper
+ 
+   kafka-3:
+     image: confluentinc/cp-kafka:7.1.3
+     environment:
+       KAFKA_BROKER_ID: 3
+       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+       KAFKA_LISTENERS: DOCKER://:9092, LOCALHOST://:9083
+       KAFKA_ADVERTISED_LISTENERS: DOCKER://kafka-3:9092, LOCALHOST://localhost:9083
+       KAFKA_INTER_BROKER_LISTENER_NAME: DOCKER
+       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: DOCKER:PLAINTEXT, LOCALHOST:PLAINTEXT
+       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3
+       KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
+     ports:
+       - 9083:9083
      depends_on:
        - zookeeper
  
@@@ -29,9 -65,14 +65,26 @@@
      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
+         kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 2 --replication-factor 3 --config min.insync.replicas=2
+         kafka-topics --bootstrap-server kafka:9092 --describe --topic test
        "
  
    cli:
      image: juplo/toolbox
      command: sleep infinity
+ 
+   producer:
+     image: juplo/simple-producer:1.0-SNAPSHOT
+     command: producer
++
++  consumer-1:
++    image: juplo/simple-consumer:1.0-SNAPSHOT
++    command: consumer-1
++
++  consumer-2:
++    image: juplo/simple-consumer:1.0-SNAPSHOT
++    command: consumer-2
++
++  consumer-3:
++    image: juplo/simple-consumer:1.0-SNAPSHOT
++    command: consumer-3

diff --combined pom.xml
index 2b39e97,4c52f37..b7c8a20
--- 1/pom.xml
--- 2/pom.xml
+++ b/pom.xml
@@@ -12,8 -12,8 +12,8 @@@
    </parent>
  
    <groupId>de.juplo.kafka</groupId>
 -  <artifactId>simple-producer</artifactId>
 -  <name>Super Simple Producer</name>
 +  <artifactId>simple-consumer</artifactId>
 +  <name>Super Simple Consumer-Group</name>
    <version>1.0-SNAPSHOT</version>
  
    <dependencies>
@@@ -34,25 -34,61 +34,61 @@@
    <build>
      <plugins>
        <plugin>
-         <groupId>org.codehaus.mojo</groupId>
-         <artifactId>exec-maven-plugin</artifactId>
-         <version>3.0.0</version>
+         <groupId>pl.project13.maven</groupId>
+         <artifactId>git-commit-id-plugin</artifactId>
+       </plugin>
+       <plugin>
+         <groupId>org.apache.maven.plugins</groupId>
+         <artifactId>maven-dependency-plugin</artifactId>
          <executions>
            <execution>
-             <id>producer</id>
+             <id>copy-dependencies</id>
+             <phase>package</phase>
+             <goals>
+               <goal>copy-dependencies</goal>
+             </goals>
              <configuration>
-               <mainClass>de.juplo.kafka.SimpleProducer</mainClass>
+               <outputDirectory>${project.build.directory}/libs</outputDirectory>
              </configuration>
            </execution>
-           <execution>
-             <id>consumer</id>
-             <configuration>
+         </executions>
+       </plugin>
+       <plugin>
+         <groupId>org.apache.maven.plugins</groupId>
+         <artifactId>maven-jar-plugin</artifactId>
+         <configuration>
+           <archive>
+             <manifest>
+               <addClasspath>true</addClasspath>
+               <classpathPrefix>libs/</classpathPrefix>
 -              <mainClass>de.juplo.kafka.SimpleProducer</mainClass>
 +              <mainClass>de.juplo.kafka.SimpleConsumer</mainClass>
-             </configuration>
+             </manifest>
+           </archive>
+         </configuration>
+       </plugin>
+       <plugin>
+         <groupId>io.fabric8</groupId>
+         <artifactId>docker-maven-plugin</artifactId>
+         <version>0.33.0</version>
+         <configuration>
+           <images>
+             <image>
+               <name>juplo/%a:%v</name>
+             </image>
+           </images>
+         </configuration>
+         <executions>
+           <execution>
+              <id>build</id>
+              <phase>package</phase>
+              <goals>
+                <goal>build</goal>
+              </goals>
            </execution>
          </executions>
        </plugin>
      </plugins>
    </build>
  
+ 
  </project>