Skip to content

fix(queue-manager-replicated): migrate Kafka tests to Testcontainers 2.x API #1225

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ehsavoie merged 1 commit into from
Oct 15, 2026
+10 −10
Merged

fix(queue-manager-replicated): migrate Kafka tests to Testcontainers 2.x API #1225

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 8 additions & 10 deletions .../sdk/extras/queuemanager/replicated/tests/multiinstance/MultiInstanceReplicationTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@
import org.a2aproject.sdk.spec.Message;
import org.a2aproject.sdk.spec.Task;
import org.a2aproject.sdk.spec.TaskIdParams;
import org.a2aproject.sdk.spec.TaskQueryParams;
import org.a2aproject.sdk.spec.TaskState;
import org.a2aproject.sdk.spec.TransportProtocol;
import org.a2aproject.sdk.testutils.docker.RequiresDocker;
Expand All @@ -40,12 +39,12 @@
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.KafkaContainer;
import org.testcontainers.containers.Network;
import org.testcontainers.containers.PostgreSQLContainer;
import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.images.builder.ImageFromDockerfile;
import org.testcontainers.junit.jupiter.Testcontainers;
import org.testcontainers.kafka.KafkaContainer;
import org.testcontainers.utility.DockerImageName;

/**
Expand All @@ -62,7 +61,7 @@
@RequiresDocker
public class MultiInstanceReplicationTest {

private static final String KAFKA_IMAGE = "confluentinc/cp-kafka:7.6.1";
private static final String KAFKA_IMAGE = "mirror.gcr.io/apache/kafka:4.2.0";
private static final String POSTGRES_IMAGE = "postgres:16-alpine";

private static Network network;
Expand All @@ -83,14 +82,14 @@ public class MultiInstanceReplicationTest {
public static void setup() {
// Create a shared network for all containers
network = Network.newNetwork();

// Start Kafka container
kafka = new KafkaContainer(DockerImageName.parse(KAFKA_IMAGE))
kafka = new KafkaContainer(DockerImageName.parse(KAFKA_IMAGE)
.asCompatibleSubstituteFor("apache/kafka"))
.withNetwork(network)
.withNetworkAliases("kafka")
.withEnv("KAFKA_AUTO_CREATE_TOPICS_ENABLE", "true");
.withListener("kafka:19092");
kafka.start();

// Start PostgreSQL container
postgres = new PostgreSQLContainer<>(DockerImageName.parse(POSTGRES_IMAGE))
.withNetwork(network)
Expand All @@ -101,8 +100,7 @@ public static void setup() {
postgres.start();

// Get Kafka bootstrap servers for app configuration
// Kafka is accessible within the Docker network as "kafka:9092"
String kafkaBootstrapServers = "kafka:9092";
String kafkaBootstrapServers = "kafka:19092";

// PostgreSQL connection details for apps (using network alias)
String dbUrl = "jdbc:postgresql://postgres:5432/a2adb";
Expand Down
2 changes: 2 additions & 0 deletions .../queue-manager-replicated/tests-single-instance/src/test/resources/application.properties
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,8 @@ mp.messaging.incoming.replicated-events-in.value.deserializer=org.apache.kafka.c

# Dev Services for Kafka will automatically start a broker for us
quarkus.kafka.devservices.enabled=true
# Use JVM image instead of native — native image fails on rootless Podman (config dir not writable)
quarkus.kafka.devservices.image-name=mirror.gcr.io/apache/kafka:4.2.0

# Enhanced configuration for faster and more reliable tests
quarkus.kafka.devservices.topic-partitions."replicated-events"=1
Expand Down
Loading