特牛网址导航

kafka 工具类(scala版)_kafkacustomer scala utils-CSDN博客

网友收藏
文章浏览阅读972次。object MyKafkaUtil { private val properties: Properties = PropertiesUtil.load("config.properties") val broker_list = properties.getProperty("kafka.broker.list") // kafka消费者配置 val kafkaParam ..._kafkacustomer scala utils