Merge branch 'main' into apache-docker

Author: rajadilipkolli

kafka-streams/analytics-spring-cloud-streams-kafka-consumer/pom.xml

@@ -15,7 +15,7 @@
 	<description>Demo project for Spring Boot and Kafka Consumer StreamCapabilities</description>
 
 	<properties>
-		<java.version>17</java.version>
+		<java.version>21</java.version>
 		<spring-cloud.version>2024.0.0-M1</spring-cloud.version>
 		<springdoc-openapi.version>2.6.0</springdoc-openapi.version>
 

kafka-streams/analytics-spring-cloud-streams-kafka-consumer/src/test/java/com/example/analytics/TestAnalyticsConsumerApplication.java

@@ -13,7 +13,7 @@
 public class TestAnalyticsConsumerApplication {
 
     private static final DockerImageName KAFKA_IMAGE_NAME =
-            DockerImageName.parse("apache/kafka").withTag("3.7.1");
+            DockerImageName.parse("apache/kafka-native").withTag("3.8.0");
 
     @Bean
     @ServiceConnection

kafka-streams/analytics-spring-cloud-streams-kafka-producer/pom.xml

@@ -17,7 +17,7 @@
 	<description>Demo project for Spring Boot and Kafka Producer StreamCapabilities</description>
 
 	<properties>
-		<java.version>17</java.version>
+		<java.version>21</java.version>
 		<spring-cloud.version>2024.0.0-M1</spring-cloud.version>
 
 		<spotless.version>2.43.0</spotless.version>

kafka-streams/analytics-spring-cloud-streams-kafka-producer/src/test/java/com/example/analytics/TestAnalyticsProducerApplication.java

@@ -16,7 +16,7 @@ class TestAnalyticsProducerApplication {
     @ServiceConnection
     KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) {
         KafkaContainer kafkaContainer =
-                new KafkaContainer(DockerImageName.parse("apache/kafka").withTag("3.7.1"));
+                new KafkaContainer(DockerImageName.parse("apache/kafka-native").withTag("3.8.0"));
         propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
         return kafkaContainer;
     }