Skip to content

Commit f2ae20a

Browse files
authored
KAFKA-18316 Fix to Kraft or remove tests associate with Zk Broker config in ConnectionQuotasTest (#18279)
Reviewers: Chia-Ping Tsai <[email protected]>
1 parent 96527be commit f2ae20a

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,11 +66,12 @@ class ConnectionQuotasTest {
6666
}
6767

6868
def brokerPropsWithDefaultConnectionLimits: Properties = {
69-
val props = TestUtils.createBrokerConfig(0, TestUtils.MockZkConnect, port = 0)
69+
val props = TestUtils.createBrokerConfig(0, null, port = 0)
7070
props.put(SocketServerConfigs.LISTENERS_CONFIG, "EXTERNAL://localhost:0,REPLICATION://localhost:1,ADMIN://localhost:2")
7171
// ConnectionQuotas does not limit inter-broker listener even when broker-wide connection limit is reached
7272
props.put(ReplicationConfigs.INTER_BROKER_LISTENER_NAME_CONFIG, "REPLICATION")
73-
props.put(SocketServerConfigs.LISTENER_SECURITY_PROTOCOL_MAP_CONFIG, "EXTERNAL:PLAINTEXT,REPLICATION:PLAINTEXT,ADMIN:PLAINTEXT")
73+
props.put(SocketServerConfigs.ADVERTISED_LISTENERS_CONFIG, "REPLICATION://localhost:1")
74+
props.put(SocketServerConfigs.LISTENER_SECURITY_PROTOCOL_MAP_CONFIG, "PLAINTEXT:PLAINTEXT,CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT,REPLICATION:PLAINTEXT,ADMIN:PLAINTEXT")
7475
props.put(QuotaConfig.NUM_QUOTA_SAMPLES_CONFIG, numQuotaSamples.toString)
7576
props.put(QuotaConfig.QUOTA_WINDOW_SIZE_SECONDS_CONFIG, quotaWindowSizeSeconds.toString)
7677
props

0 commit comments

Comments
 (0)