We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f89b38c commit 907a173Copy full SHA for 907a173
embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala
@@ -47,22 +47,22 @@ class EmbeddedKafkaObjectSpec
47
48
"start and stop a specific Kafka" in {
49
val firstServer = EmbeddedKafka.start()(
50
- EmbeddedKafkaConfig(kafkaPort = 7000, controllerPort = 7001)
+ EmbeddedKafkaConfig(kafkaPort = 9000, controllerPort = 9001)
51
)
52
EmbeddedKafka.start()(
53
EmbeddedKafkaConfig(kafkaPort = 8000, controllerPort = 8001)
54
55
56
- expectedServerStatus(7001, Available)
57
- expectedServerStatus(7000, Available)
+ expectedServerStatus(9001, Available)
+ expectedServerStatus(9000, Available)
58
59
expectedServerStatus(8001, Available)
60
expectedServerStatus(8000, Available)
61
62
EmbeddedKafka.stop(firstServer)
63
64
- expectedServerStatus(7000, NotAvailable)
65
- expectedServerStatus(7001, NotAvailable)
+ expectedServerStatus(9000, NotAvailable)
+ expectedServerStatus(9001, NotAvailable)
66
67
68
0 commit comments