Replace Redpanda testcontainers with Apache Kafka native

pom.xml

@@ -511,7 +511,7 @@
         </dependency>
         <dependency>
             <groupId>org.testcontainers</groupId>
-            <artifactId>redpanda</artifactId>
+            <artifactId>kafka</artifactId>
             <version>${lib.testcontainers.version}</version>
             <scope>test</scope>
         </dependency>
@@ -801,7 +801,7 @@
                 </dependency>
                 <dependency>
                     <groupId>org.testcontainers</groupId>
-                    <artifactId>redpanda</artifactId>
+                    <artifactId>kafka</artifactId>
                     <version>${lib.testcontainers.version}</version>
                     <scope>compile</scope>
                 </dependency>

src/main/java/org/dependencytrack/common/ConfigKey.java

@@ -62,7 +62,7 @@ public enum ConfigKey implements Config.Key {
 
     DEV_SERVICES_ENABLED("dev.services.enabled", false),
     DEV_SERVICES_IMAGE_FRONTEND("dev.services.image.frontend", "ghcr.io/dependencytrack/hyades-frontend:snapshot"),
-    DEV_SERVICES_IMAGE_KAFKA("dev.services.image.kafka", "docker.redpanda.com/vectorized/redpanda:v24.2.4"),
+    DEV_SERVICES_IMAGE_KAFKA("dev.services.image.kafka", "apache/kafka-native:3.8.0"),
     DEV_SERVICES_IMAGE_POSTGRES("dev.services.image.postgres", "postgres:16");
 
     private final String propertyName;

src/main/java/org/dependencytrack/dev/DevServicesInitializer.java

@@ -93,9 +93,9 @@ public void contextInitialized(final ServletContextEvent event) {
             final Constructor<?> postgresContainerConstructor = postgresContainerClass.getDeclaredConstructor(String.class);
             postgresContainer = (AutoCloseable) postgresContainerConstructor.newInstance(getProperty(DEV_SERVICES_IMAGE_POSTGRES));
 
-            // TODO: Detect when Apache Kafka is requested vs. when Redpanda is requested,
+            // TODO: Detect when Apache Kafka is requested vs. when Kafka is requested,
             //   and pick the corresponding Testcontainers class accordingly.
-            final Class<?> kafkaContainerClass = Class.forName("org.testcontainers.redpanda.RedpandaContainer");
+            final Class<?> kafkaContainerClass = Class.forName("org.testcontainers.kafka.KafkaContainer");
             final Constructor<?> kafkaContainerConstructor = kafkaContainerClass.getDeclaredConstructor(String.class);
             kafkaContainer = (AutoCloseable) kafkaContainerConstructor.newInstance(getProperty(DEV_SERVICES_IMAGE_KAFKA));
 

src/main/resources/application.properties

@@ -1321,7 +1321,7 @@ dev.services.image.frontend=ghcr.io/dependencytrack/hyades-frontend:snapshot
 #
 # @category: Development
 # @type:     string
-dev.services.image.kafka=docker.redpanda.com/vectorized/redpanda:v24.2.4
+dev.services.image.kafka=apache/kafka-native:3.8.0
 
 # The image to use for the PostgreSQL dev services container.
 #

src/test/java/org/dependencytrack/event/kafka/processor/api/ProcessorManagerTest.java

@@ -33,8 +33,7 @@
 import org.junit.Before;
 import org.junit.Rule;
 import org.junit.Test;
-import org.testcontainers.redpanda.RedpandaContainer;
-import org.testcontainers.utility.DockerImageName;
+import org.testcontainers.kafka.KafkaContainer;
 
 import java.time.Duration;
 import java.util.List;
@@ -60,8 +59,7 @@
 public class ProcessorManagerTest {
 
     @Rule
-    public RedpandaContainer kafkaContainer = new RedpandaContainer(DockerImageName
-            .parse("docker.redpanda.com/vectorized/redpanda:v24.2.4"));
+    public KafkaContainer kafkaContainer = new KafkaContainer("apache/kafka-native:3.8.0");
 
     private AdminClient adminClient;
     private Producer<String, String> producer;