Kafka Producer 生产者

val props = new Properties()
    props.put("bootstrap.servers", "localhost:9092")
    props.put("acks", "all")
    props.put("retries", 0)
    props.put("batch.size", 16384)
    props.put("linger.ms", 1)
    props.put("buffer.memory", 33554432)
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer")
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer")

    val producer = new KafkaProducer[String,String](props)
    /**
     *创建一个具有指定时间戳的记录以发送到指定的主题和分区
     *
     *@param topic 记录将附加到的主题
     *@param partition 记录应发送到的分区
     *@param timestamp 记录的时间戳
     *@param key 将包含在记录中的键
     *@param value 记录内容
     */
    for(i<- 0 until 100)
    producer.send(new ProducerRecord[String, String]("my-topic", Integer.toString(i), Integer.toString(i)))

    producer.close()