Add jmx_port config.
Closed this issue · 5 comments
The CMAK application has the following line:
val jmxPortResult = fieldExtended[Int]("jmx_port")(json)
It would be nice to be able to configure the JMX port in the config file. Not every Kafka is exposing JMX on TCP 12345.
Dear @tdixonspin
Why did you put this question here ? Please explain
I honestly wasn't sure where to put like a feature request. I just noticed that I wasn't able to set a custom JMX port, and it looks like CMAK pulls it from the config, but your operator doesn't account for it in the clusterConfigShared schema.
I honestly wasn't sure where to put like a feature request. I just noticed that I wasn't able to set a custom JMX port, and it looks like CMAK pulls it from the config, but your operator doesn't account for it in the clusterConfigShared schema.
how do you handle JMX port configuration outside of K8S ?
What are exact actions, plz report here.
Nothing specific outside of K8S. Right now we are exposing TCP 7075 for JMX metrics. It looks like CMAK takes the jmx_port object in for this object:
case class BrokerIdentity(id: Int, host: String, jmxPort: Int, secure: Boolean, nonSecure:Boolean, endpoints: Map[SecurityProtocol, Int]) { def endpointsString: String = endpoints.toList.map(tpl => s"${tpl._1.stringId}:${tpl._2}").mkString(",") }
Duplicate of #13