3131import org .a2aproject .sdk .spec .Message ;
3232import org .a2aproject .sdk .spec .Task ;
3333import org .a2aproject .sdk .spec .TaskIdParams ;
34- import org .a2aproject .sdk .spec .TaskQueryParams ;
3534import org .a2aproject .sdk .spec .TaskState ;
3635import org .a2aproject .sdk .spec .TransportProtocol ;
3736import org .a2aproject .sdk .testutils .docker .RequiresDocker ;
4039import org .junit .jupiter .api .BeforeAll ;
4140import org .junit .jupiter .api .Test ;
4241import org .testcontainers .containers .GenericContainer ;
43- import org .testcontainers .containers .KafkaContainer ;
4442import org .testcontainers .containers .Network ;
4543import org .testcontainers .containers .PostgreSQLContainer ;
4644import org .testcontainers .containers .wait .strategy .Wait ;
4745import org .testcontainers .images .builder .ImageFromDockerfile ;
4846import org .testcontainers .junit .jupiter .Testcontainers ;
47+ import org .testcontainers .kafka .KafkaContainer ;
4948import org .testcontainers .utility .DockerImageName ;
5049
5150/**
6261@ RequiresDocker
6362public class MultiInstanceReplicationTest {
6463
65- private static final String KAFKA_IMAGE = "confluentinc/cp- kafka:7.6.1 " ;
64+ private static final String KAFKA_IMAGE = "mirror.gcr.io/apache/ kafka:4.2.0 " ;
6665 private static final String POSTGRES_IMAGE = "postgres:16-alpine" ;
6766
6867 private static Network network ;
@@ -83,14 +82,14 @@ public class MultiInstanceReplicationTest {
8382 public static void setup () {
8483 // Create a shared network for all containers
8584 network = Network .newNetwork ();
86-
85+
8786 // Start Kafka container
88- kafka = new KafkaContainer (DockerImageName .parse (KAFKA_IMAGE ))
87+ kafka = new KafkaContainer (DockerImageName .parse (KAFKA_IMAGE )
88+ .asCompatibleSubstituteFor ("apache/kafka" ))
8989 .withNetwork (network )
90- .withNetworkAliases ("kafka" )
91- .withEnv ("KAFKA_AUTO_CREATE_TOPICS_ENABLE" , "true" );
90+ .withListener ("kafka:19092" );
9291 kafka .start ();
93-
92+
9493 // Start PostgreSQL container
9594 postgres = new PostgreSQLContainer <>(DockerImageName .parse (POSTGRES_IMAGE ))
9695 .withNetwork (network )
@@ -101,8 +100,7 @@ public static void setup() {
101100 postgres .start ();
102101
103102 // Get Kafka bootstrap servers for app configuration
104- // Kafka is accessible within the Docker network as "kafka:9092"
105- String kafkaBootstrapServers = "kafka:9092" ;
103+ String kafkaBootstrapServers = "kafka:19092" ;
106104
107105 // PostgreSQL connection details for apps (using network alias)
108106 String dbUrl = "jdbc:postgresql://postgres:5432/a2adb" ;
0 commit comments