该模块目标是将数据写入kafka,所以需要实现kafka配置文件的外部化,写一个工具类来读取kafka配置
utils包下新建scala class
scala示例(hello world)
package utils
object PropertyUtil {
def main(args: Array[String]): Unit = {
println("hello world")
}
}
Run
该模块目标是将数据写入kafka,所以需要实现kafka配置文件的外部化,写一个工具类来读取kafka配置
utils包下新建scala class
scala示例(hello world)
package utils
object PropertyUtil {
def main(args: Array[String]): Unit = {
println("hello world")
}
}
Run