NIO与高性能框架Netty从入门到源码剖析
2023-08-19 16:31 作者:每天3个拼课小技巧__ | 我要投稿
编写代码
需要用到的类KafkaProducer
:需要创建一个生产者对象,用来发送数据。ProducerConfig
:获取所需的一系列配置参数。ProducerRecord
:每条数据都要封装成一个ProducerRecord对象。
1.不带回调函数的API
//1.创建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);