Scala实现Kafka的producer

package kafka import java.util.Properties import org.apache.kafka.clients.producer.{KafkaProducer, ProducerRecord} object KafkaProducer { def producerSendMsg()={ val props = new Properties
相关文章
相关标签/搜索