Kafka 2.7 upgrade

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}" ]
@@ -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: {}

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: {}

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>

messaging/kafka-avro-reactive-messaging/src/test/java/io/quarkus/ts/openshift/messaging/kafka/containers/StrimziKafkaResource.java

@@ -20,8 +20,7 @@ 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);
+        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);
 

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>

messaging/kafka-streams-reactive-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();

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.13</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>