Java API创建kafka生产者

//配置文件对象
    val properties: Properties = new Properties()

    //指定kafka连接的参数
    //指定kafka broker 列表
    properties.setProperty("bootstrap.servers","master:9092,node1:9092,node2:9092")
    //指定key value 序列化类
    properties.setProperty("key.serializer","org.apache.kafka.common.serialization.StringSerializer")
    properties.setProperty("value.serializer","org.apache.kafka.common.serialization.StringSerializer")


    val kafkaProducer: KafkaProducer[String, String] = new KafkaProducer[String, String](properties)