Merge der Upgrades für Confluent/Spring-Boot ('endless-stream-producer')
authorKai Moritz <kai@juplo.de>
Fri, 22 Jul 2022 18:23:55 +0000 (20:23 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 22 Jul 2022 18:23:55 +0000 (20:23 +0200)
1  2 
docker-compose.yml
pom.xml

diff --combined 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
      command: sleep infinity
  
    producer:
 -    image: juplo/endless-producer:1.0-SNAPSHOT
 +    image: juplo/rest-producer:1.0-SNAPSHOT
      ports:
        - 8080:8880
      environment:
        producer.bootstrap-server: kafka:9092
        producer.client-id: producer
        producer.topic: test
 -      producer.throttle-ms: 200
 +
 +  consumer:
 +    image: juplo/endless-consumer:1.0-SNAPSHOT
 +    ports:
 +      - 8081:8081
 +    environment:
 +      consumer.bootstrap-server: kafka:9092
 +      consumer.client-id: my-group
 +      consumer.client-id: consumer
 +      consumer.topic: test
diff --combined pom.xml
+++ b/pom.xml
@@@ -7,14 -7,13 +7,14 @@@
    <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>
  
    <groupId>de.juplo.kafka</groupId>
 -  <artifactId>endless-producer</artifactId>
 -  <name>Endless Producer: a Simple Producer that endlessly writes numbers into a topic</name>
 +  <artifactId>rest-producer</artifactId>
 +  <name>REST Producer</name>
 +  <description>A Simple Producer that takes messages via POST and confirms successs</description>
    <version>1.0-SNAPSHOT</version>
  
    <dependencies>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
      </dependency>
 +    <dependency>
 +      <groupId>org.springframework.kafka</groupId>
 +      <artifactId>spring-kafka</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>