NIO與高性能框架Netty從入門到源碼剖析
2023-08-19 16:31 作者:每天3個拼課小技巧__ | 我要投稿
編寫代碼
需要用到的類KafkaProducer：需要創(chuàng)建一個生產者對象，用來發(fā)送數據。ProducerConfig：獲取所需的一系列配置參數。ProducerRecord：每條數據都要封裝成一個ProducerRecord對象。
1.不帶回調函數的API
? ?//1.創(chuàng)建Kafka生產者的配置信息
? ? ? ?Properties properties = new Properties();
? ? ? ?//2.指定連接的kafka集群
? ? ? ?properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.235.3:9092");
? ? ? ?//3.ACK應答級別
? ? ? ?properties.put(ProducerConfig.ACKS_CONFIG, "all");
? ? ? ?//4.重試次數
? ? ? ?properties.put(ProducerConfig.RETRIES_CONFIG, 3);
? ? ? ?//5.批次大小
? ? ? ?properties.put(ProducerConfig.BATCH_SIZE_CONFIG, 16384);
? ? ? ?//6.等待時間
? ? ? ?properties.put(ProducerConfig.LINGER_MS_CONFIG, 1);
標簽：
