Skip to content

Commit 11881bf

Browse files
authored
Fix Kafka listeners and advertised listeners config to come out of sync (#11068)
1 parent c8aa7c7 commit 11881bf

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

modules/kafka/src/main/java/org/testcontainers/kafka/ConfluentKafkaContainer.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import org.testcontainers.utility.DockerImageName;
77

88
import java.util.ArrayList;
9-
import java.util.HashSet;
9+
import java.util.LinkedHashSet;
1010
import java.util.List;
1111
import java.util.Set;
1212
import java.util.function.Supplier;
@@ -22,9 +22,9 @@ public class ConfluentKafkaContainer extends GenericContainer<ConfluentKafkaCont
2222

2323
private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse("confluentinc/cp-kafka");
2424

25-
private final Set<String> listeners = new HashSet<>();
25+
private final Set<String> listeners = new LinkedHashSet<>();
2626

27-
private final Set<Supplier<String>> advertisedListeners = new HashSet<>();
27+
private final Set<Supplier<String>> advertisedListeners = new LinkedHashSet<>();
2828

2929
public ConfluentKafkaContainer(String imageName) {
3030
this(DockerImageName.parse(imageName));

modules/kafka/src/main/java/org/testcontainers/kafka/KafkaContainer.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import org.testcontainers.utility.DockerImageName;
77

88
import java.util.ArrayList;
9-
import java.util.HashSet;
9+
import java.util.LinkedHashSet;
1010
import java.util.List;
1111
import java.util.Set;
1212
import java.util.function.Supplier;
@@ -28,9 +28,9 @@ public class KafkaContainer extends GenericContainer<KafkaContainer> {
2828

2929
private static final String STARTER_SCRIPT = "/tmp/testcontainers_start.sh";
3030

31-
private final Set<String> listeners = new HashSet<>();
31+
private final Set<String> listeners = new LinkedHashSet<>();
3232

33-
private final Set<Supplier<String>> advertisedListeners = new HashSet<>();
33+
private final Set<Supplier<String>> advertisedListeners = new LinkedHashSet<>();
3434

3535
public KafkaContainer(String imageName) {
3636
this(DockerImageName.parse(imageName));

0 commit comments

Comments
 (0)