IDCF王力杰精益看板进阶训练营

    //7.RecordAccmulator缓冲区大小 个人公告有课        properties.put(ProducerConfig.BUFFER_MEMORY_CONFIG, 3355432);        //8.Key,Value序列化类        properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");        properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");        //9.创建生产者对象        KafkaProducer<String, String> producer = new KafkaProducer<>(properties);        for (int i = 0; i < 10; i++) {            //10.发送数据            producer.send(new ProducerRecord<String, String>("first", "kafka_message_" + i));        }        //11.关闭资源        producer.close();