创建读取配置属性kafka.properties的工具类,object PropertyUtil
package utils
import java.util.Properties
// PropertyUtil读取配置文件的工具类
object PropertyUtil {
// 1 import java.util.Properties
val properties = new Properties
// 4 异常处理,加try catch语句(ctrl Alt + t)
try {
// 2 加载配置文件,将其转换为输入流
val inputStream = ClassLoader.getSystemResourceAsStream("kafka.properties")
// 3 加载配置文件属性
properties.load(inputStream)
} catch {
// 5
case e: Exception => e.getStackTrace
} finally {}
// 6 封装一个方法用于快速获取“key-value”
def getProperty(key: String): String = properties.getProperty(key)
}