生产者发送消息的三种模式
1.发后即忘(常用)-------性能最高,可靠性最差
2.同步
3.异步
重试
Properties props = new Properties();
//配置kafka生产者重试次数
props.put(ProducerConfig.RETRIES_CONFIG, 3);
1.发后即忘(常用)-------性能最高,可靠性最差
2.同步
3.异步
Properties props = new Properties();
//配置kafka生产者重试次数
props.put(ProducerConfig.RETRIES_CONFIG, 3);
本文标题:kafka---生产者
本文链接:https://www.haomeiwen.com/subject/jwwemhtx.html
网友评论