IDCF王力杰精益看板進階訓(xùn)練營
2023-08-19 16:33 作者:每天3個拼課小技巧__ | 我要投稿
? ? //7.RecordAccmulator緩沖區(qū)大小 個人公告有課??? ? ? 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.創(chuàng)建生產(chǎn)者對象
? ? ? ?KafkaProducer<String, String> producer = new KafkaProducer<>(properties);
? ? ? ?for (int i = 0; i < 10; i++) {
? ? ? ? ? ?//10.發(fā)送數(shù)據(jù)
? ? ? ? ? ?producer.send(new ProducerRecord<String, String>("first", "kafka_message_" + i));
? ? ? ?}
? ? ? ?//11.關(guān)閉資源
? ? ? ?producer.close();
標簽：
