diff --git a/core/src/test/scala/unit/kafka/server/ControllerApisTest.scala b/core/src/test/scala/unit/kafka/server/ControllerApisTest.scala index fc0a38b6cd252..3533fcfdee2cd 100644 --- a/core/src/test/scala/unit/kafka/server/ControllerApisTest.scala +++ b/core/src/test/scala/unit/kafka/server/ControllerApisTest.scala @@ -67,7 +67,7 @@ class ControllerApisTest { private def createControllerApis(authorizer: Option[Authorizer], supportedFeatures: Map[String, VersionRange] = Map.empty): ControllerApis = { val props = new Properties() - props.put(KafkaConfig.NodeIdProp, nodeId) + props.put(KafkaConfig.NodeIdProp, nodeId: java.lang.Integer) props.put(KafkaConfig.ProcessRolesProp, "controller") new ControllerApis( requestChannel,