Merge pull request #2797 from smallrye/dependabot/maven/main/io.strimzi-strimzi-test-container-0.108.0

Bump io.strimzi:strimzi-test-container from 0.107.0 to 0.108.0

Author: ozangunalp

pom.xml

@@ -116,7 +116,7 @@
     <slf4j-log4j12.version>2.0.16</slf4j-log4j12.version>
     <slf4j-reload4j.version>2.0.16</slf4j-reload4j.version>
     <opencsv.version>5.9</opencsv.version>
-    <strimzi-test-container.version>0.107.0</strimzi-test-container.version>
+    <strimzi-test-container.version>0.108.0</strimzi-test-container.version>
 
     <revapi-maven-plugin.version>0.15.0</revapi-maven-plugin.version>
     <revapi-java.version>0.28.1</revapi-java.version>

smallrye-reactive-messaging-kafka-test-companion/src/main/java/io/smallrye/reactive/messaging/kafka/companion/test/KafkaBrokerExtension.java

@@ -59,6 +59,7 @@ public static <T extends StrimziKafkaContainer> T configureKafkaContainer(T cont
         container.withKafkaVersion(kafkaVersion);
         Map<String, String> config = new HashMap<>();
         config.put("log.cleaner.enable", "false");
+        config.put("group.initial.rebalance.delay.ms", "0");
         container.withKafkaConfigurationMap(config);
         return container;
     }

smallrye-reactive-messaging-kafka-test-companion/src/test/java/io/smallrye/reactive/messaging/kafka/companion/ConsumerTest.java

@@ -218,7 +218,8 @@ void testConsumerWithCommitSync() {
 
         ConsumerTask<String, String> task = consumer.fromTopics(topic, Duration.ofSeconds(5));
 
-        await().untilAsserted(() -> assertThat(consumer.committed().get(tp(topic, 0)).offset()).isEqualTo(101L));
+        await().untilAsserted(() -> assertThat(consumer.committed().get(tp(topic, 0))).isNotNull()
+                .extracting(OffsetAndMetadata::offset).isEqualTo(101L));
 
         task.awaitCompletion();
     }