Skip to content

Commit 00322db

Browse files
committed
Fix unit test
1 parent 400f6ae commit 00322db

File tree

1 file changed

+9
-20
lines changed

1 file changed

+9
-20
lines changed

pkg/resources/kafka/configmap_test.go

Lines changed: 9 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1056,12 +1056,6 @@ process.roles=broker,controller
10561056
{
10571057
MountPath: "/test-kafka-logs",
10581058
},
1059-
{
1060-
MountPath: "/test-kafka-logs-50",
1061-
},
1062-
{
1063-
MountPath: "/test-kafka-logs-100",
1064-
},
10651059
},
10661060
},
10671061
ReadOnlyConfig: "migration.broker.controllerQuorumConfigEnabled=true\nmigration.broker.kRaftMode=false",
@@ -1074,12 +1068,6 @@ process.roles=broker,controller
10741068
{
10751069
MountPath: "/test-kafka-logs",
10761070
},
1077-
{
1078-
MountPath: "/test-kafka-logs-50",
1079-
},
1080-
{
1081-
MountPath: "/test-kafka-logs-100",
1082-
},
10831071
},
10841072
},
10851073
ReadOnlyConfig: "migration.broker.controllerQuorumConfigEnabled=false\nmigration.broker.kRaftMode=true",
@@ -1121,11 +1109,11 @@ process.roles=broker,controller
11211109
},
11221110
{
11231111
Name: "broker-200",
1124-
Address: "kafka-100.kafka.svc.cluster.local:9092",
1112+
Address: "kafka-200.kafka.svc.cluster.local:9092",
11251113
},
11261114
{
11271115
Name: "broker-300",
1128-
Address: "kafka-100.kafka.svc.cluster.local:9092",
1116+
Address: "kafka-300.kafka.svc.cluster.local:9092",
11291117
},
11301118
},
11311119
},
@@ -1144,12 +1132,12 @@ process.roles=broker,controller
11441132
Address: "kafka-100.kafka.svc.cluster.local:9093",
11451133
},
11461134
{
1147-
Name: "broker-100",
1148-
Address: "kafka-100.kafka.svc.cluster.local:9093",
1135+
Name: "broker-200",
1136+
Address: "kafka-200.kafka.svc.cluster.local:9093",
11491137
},
11501138
{
1151-
Name: "broker-100",
1152-
Address: "kafka-100.kafka.svc.cluster.local:9093",
1139+
Name: "broker-300",
1140+
Address: "kafka-300.kafka.svc.cluster.local:9093",
11531141
},
11541142
},
11551143
},
@@ -1192,6 +1180,9 @@ metric.reporters=com.linkedin.kafka.cruisecontrol.metricsreporter.CruiseControlM
11921180
`,
11931181
`advertised.listeners=INTERNAL://kafka-200.kafka.svc.cluster.local:9092
11941182
broker.id=200
1183+
control.plane.listener.name=CONTROLLER
1184+
controller.listener.names=CONTROLLER
1185+
11951186
cruise.control.metrics.reporter.bootstrap.servers=kafka-all-broker.kafka.svc.cluster.local:9092
11961187
cruise.control.metrics.reporter.kubernetes.mode=true
11971188
inter.broker.listener.name=INTERNAL
@@ -1201,8 +1192,6 @@ log.dirs=/test-kafka-logs/kafka
12011192
metric.reporters=com.linkedin.kafka.cruisecontrol.metricsreporter.CruiseControlMetricsReporter
12021193
`,
12031194
`advertised.listeners=INTERNAL://kafka-300.kafka.svc.cluster.local:9092
1204-
controller.listener.names=CONTROLLER
1205-
12061195
cruise.control.metrics.reporter.bootstrap.servers=kafka-all-broker.kafka.svc.cluster.local:9092
12071196
cruise.control.metrics.reporter.kubernetes.mode=true
12081197
inter.broker.listener.name=INTERNAL

0 commit comments

Comments
 (0)