Skip to content

Commit 2e0ef57

Browse files
Fix register listener for kafka docs (#10268)
1 parent b3bcf36 commit 2e0ef57

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

docs/modules/kafka.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ There are scenarios where additional listeners are needed because the consumer/p
8585
container in the same network or a different process where the port to connect differs from the default exposed port. E.g [Toxiproxy](../../modules/toxiproxy/).
8686

8787
<!--codeinclude-->
88-
[Register additional listener](../../modules/kafka/src/test/java/org/testcontainers/containers/KafkaContainerTest.java) inside_block:registerListener
88+
[Register additional listener](../../modules/kafka/src/test/java/org/testcontainers/kafka/KafkaContainerTest.java) inside_block:registerListener
8989
<!--/codeinclude-->
9090

9191
Container defined in the same network:

modules/kafka/src/test/java/org/testcontainers/containers/KafkaContainerTest.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -189,11 +189,9 @@ public void testKraftPrecedenceOverEmbeddedZookeeper() throws Exception {
189189
public void testUsageWithListener() throws Exception {
190190
try (
191191
Network network = Network.newNetwork();
192-
// registerListener {
193192
KafkaContainer kafka = new KafkaContainer(KAFKA_KRAFT_TEST_IMAGE)
194193
.withListener(() -> "kafka:19092")
195194
.withNetwork(network);
196-
// }
197195
// createKCatContainer {
198196
GenericContainer<?> kcat = new GenericContainer<>("confluentinc/cp-kcat:7.9.0")
199197
.withCreateContainerCmdModifier(cmd -> {

modules/kafka/src/test/java/org/testcontainers/kafka/KafkaContainerTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,11 @@ public void testUsage() throws Exception {
2525
public void testUsageWithListener() throws Exception {
2626
try (
2727
Network network = Network.newNetwork();
28+
// registerListener {
2829
KafkaContainer kafka = new KafkaContainer("apache/kafka-native:3.8.0")
2930
.withListener("kafka:19092")
3031
.withNetwork(network);
32+
// }
3133
KCatContainer kcat = new KCatContainer().withNetwork(network)
3234
) {
3335
kafka.start();

0 commit comments

Comments
 (0)