package kafka.common
import java.net.URL
import java.util.jar.{Attributes, Manifest}
import com.yammer.metrics.core.Gauge
import kafka.metrics.KafkaMetricsGroup
object AppInfo extends KafkaMetricsGroup {
private var isRegistered = false
private val lock = new Object()
def registerInfo(): Unit = {
lock.synchronized {
if (isRegistered) {
return
}
}
try {
val clazz = AppInfo.getClass
val className = clazz.getSimpleName + ".class"
val classPath = clazz.getResource(className).toString
if (!classPath.startsWith("jar")) {
return
}
val manifestPath = classPath.substring(0, classPath.lastIndexOf("!") + 1) + "/META-INF/MANIFEST.MF"
val mf = new Manifest
mf.read(new URL(manifestPath).openStream())
val version = mf.getMainAttributes.get(new Attributes.Name("Version")).toString
newGauge("Version",
new Gauge[String] {
def value = {
version
}
})
lock.synchronized {
isRegistered = true
}
} catch {
case e: Exception =>
warn("Can't read Kafka version from MANIFEST.MF. Possible cause: %s".format(e))
}
}
}