欢迎光临散文网 会员登陆 & 注册

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);

NIO与高性能框架Netty从入门到源码剖析的评论 (共 条)

分享到微博请遵守国家法律