1、工具方法
import java.util.Properties
object PropertyUtil {
val properties = new Properties
try {
val stream = ClassLoader.getSystemResourceAsStream("kafka.properties")
properties.load(stream)
} catch {
case e:Exception => e.getStackTrace
} finally {}
def getProperties(key:String) = properties.getProperty(key)
}
2、使用
val topics = PropertyUtil.getProperties("kafka.topics")
