root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: fix KafkaTest#testIsKRaftCombinedMode (#13413) 

Reviewers: David Arthur <mumrah@gmail.com>
This commit is contained in:
Chia-Ping Tsai 2023-03-17 22:09:26 +08:00 committed by GitHub
parent ddd652c672
commit 55c238b177
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
core/src/test/scala/unit/kafka/KafkaConfigTest.scala
View File

@ -133,6 +133,7 @@ class KafkaTest {
propertiesFile.setProperty(KafkaConfig.ProcessRolesProp, "controller,broker") propertiesFile.setProperty(KafkaConfig.ProcessRolesProp, "controller,broker")
propertiesFile.setProperty(KafkaConfig.NodeIdProp, "1") propertiesFile.setProperty(KafkaConfig.NodeIdProp, "1")
propertiesFile.setProperty(KafkaConfig.QuorumVotersProp, "1@localhost:9092") propertiesFile.setProperty(KafkaConfig.QuorumVotersProp, "1@localhost:9092")
setListenerProps(propertiesFile)
val config = KafkaConfig.fromProps(propertiesFile) val config = KafkaConfig.fromProps(propertiesFile)
assertTrue(config.isKRaftCombinedMode) assertTrue(config.isKRaftCombinedMode)
} }