Kafka 2.7 upgrade

quarkus-qe · May 7, 2021 · 95be7c3 · 95be7c3
1 parent 66d0290
commit 95be7c3
Show file tree

Hide file tree

Showing 7 changed files with 11 additions and 11 deletions.
diff --git a/common/src/main/resources/deployments/kafka/amq-streams.yaml b/common/src/main/resources/deployments/kafka/amq-streams.yaml
@@ -47,7 +47,7 @@ items:
            terminationGracePeriodSeconds: 10
            containers:
              - name: kafka-broker-1
-               image: registry.redhat.io/amq7/amq-streams-kafka-24-rhel7:1.5.0
+               image: registry.redhat.io/amq7/amq-streams-kafka-27-rhel7:1.7.0
                imagePullPolicy: IfNotPresent
                command: [ "/bin/sh" ]
                args: [ "-c", "bin/kafka-server-start.sh config/server.properties --override listeners=$${KAFKA_LISTENERS} --override advertised.listeners=$${KAFKA_ADVERTISED_LISTENERS} --override zookeeper.connect=$${KAFKA_ZOOKEEPER_CONNECT}" ]

diff --git a/common/src/main/resources/deployments/kafka/strimzi.yaml b/common/src/main/resources/deployments/kafka/strimzi.yaml
@@ -47,7 +47,7 @@ items:
            terminationGracePeriodSeconds: 10
            containers:
              - name: kafka-broker-1
-               image: strimzi/kafka:0.18.0-kafka-2.5.0
+               image: quay.io/strimzi/kafka:latest-kafka-2.7.0
                imagePullPolicy: IfNotPresent
                command: [ "/bin/sh" ]
                args: [ "-c", "bin/kafka-server-start.sh config/server.properties --override listeners=$${KAFKA_LISTENERS} --override advertised.listeners=$${KAFKA_ADVERTISED_LISTENERS} --override zookeeper.connect=$${KAFKA_ZOOKEEPER_CONNECT}" ]
@@ -58,6 +58,8 @@ items:
                    value: "PLAINTEXT://0.0.0.0:9092"
                  - name: KAFKA_ZOOKEEPER_CONNECT
                    value: zookeeper-service:2181
+                 - name: LOG_DIR
+                   value: "/tmp/kafka/logs"
                ports:
                  - containerPort: 9092
                resources: {}

diff --git a/messaging/kafka-avro-reactive-messaging/pom.xml b/messaging/kafka-avro-reactive-messaging/pom.xml
@@ -60,7 +60,7 @@
         </dependency>
         <dependency>
             <groupId>io.strimzi</groupId>
-            <artifactId>test-container</artifactId>
+            <artifactId>strimzi-test-container</artifactId>
             <scope>test</scope>
         </dependency>
         <dependency>

diff --git a/...rc/test/java/io/quarkus/ts/openshift/messaging/kafka/containers/StrimziKafkaResource.java b/...rc/test/java/io/quarkus/ts/openshift/messaging/kafka/containers/StrimziKafkaResource.java
@@ -20,10 +20,8 @@ public class StrimziKafkaResource implements QuarkusTestResourceLifecycleManager
     @Override
     public Map<String, String> start() {
         Network network = Network.newNetwork();
-
-        kafkaContainer = new StrimziKafkaContainer("0.18.0-kafka-2.5.0").withNetwork(network);
-        schemaRegistry = new SchemaRegistryContainer("apicurio/apicurio-registry-mem", "1.2.2.Final", 8080).withNetwork(network)
-                .withKafka(kafkaContainer, 9092);
+        kafkaContainer = new StrimziKafkaContainer("latest-kafka-2.7.0").withNetwork(network);
+        schemaRegistry = new SchemaRegistryContainer("apicurio/apicurio-registry-mem", "1.2.2.Final", 8080).withNetwork(network).withKafka(kafkaContainer, 9092);
 
         Startables.deepStart(Stream.of(kafkaContainer, schemaRegistry)).join();
 

diff --git a/messaging/kafka-streams-reactive-messaging/pom.xml b/messaging/kafka-streams-reactive-messaging/pom.xml
@@ -41,7 +41,7 @@
         </dependency>
         <dependency>
             <groupId>io.strimzi</groupId>
-            <artifactId>test-container</artifactId>
+            <artifactId>strimzi-test-container</artifactId>
             <scope>test</scope>
         </dependency>
         <dependency>

diff --git a/...messaging/src/test/java/io/quarkus/ts/openshift/messaging/kafka/StrimziKafkaResource.java b/...messaging/src/test/java/io/quarkus/ts/openshift/messaging/kafka/StrimziKafkaResource.java
@@ -15,7 +15,7 @@ public class StrimziKafkaResource implements QuarkusTestResourceLifecycleManager
 
     @Override
     public Map<String, String> start() {
-        kafkaContainer = new StrimziKafkaContainer("0.18.0-kafka-2.5.0");
+        kafkaContainer = new StrimziKafkaContainer("latest-kafka-2.7.0");
         kafkaContainer.start();
 
         String kafkaUrl = kafkaContainer.getBootstrapServers();

diff --git a/pom.xml b/pom.xml
@@ -61,7 +61,7 @@
         <quarkus.platform.group-id>io.quarkus</quarkus.platform.group-id>
         <version.apicurio.registry.utils.serde>1.3.2.Final</version.apicurio.registry.utils.serde>
         <version.quarkiverse.apicurio.registry.client>0.0.2</version.quarkiverse.apicurio.registry.client>
-        <version.strimzi>0.20.1</version.strimzi>
+        <version.strimzi>0.22.1</version.strimzi>
         <version.apache-httpclient-fluent>4.5.12</version.apache-httpclient-fluent>
         <!-- same as Apache HTTP Client managed by Quarkus BOM -->
         <version.fusesource-jansi>2.3.2</version.fusesource-jansi>
@@ -137,7 +137,7 @@
             </dependency>
             <dependency>
                 <groupId>io.strimzi</groupId>
-                <artifactId>test-container</artifactId>
+                <artifactId>strimzi-test-container</artifactId>
                 <version>${version.strimzi}</version>
                 <scope>test</scope>
             </dependency>