kafka发送消息流程
创始人
2025-01-08 14:04:25
0

在这里插入图片描述
配置props.put(ProducerConfig.PARTITIONER_CLASS_CONFIG, RoundRobinPartitioner.class);

public Map producerConfigs(){     Map props = new HashMap<>();     props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,bootstrapServers);     props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,valueSerializer);     props.put(ProducerConfig.PARTITIONER_CLASS_CONFIG, RoundRobinPartitioner.class);     return props; }  public ProducerFactory producerFactory(){     return new DefaultKafkaProducerFactory<>(producerConfigs()); }  // 覆盖spring-kafka中的配置 @Bean public KafkaTemplate kafkaTemplate(){     return new KafkaTemplate(producerFactory()); } 

自定义消息拦截器

public class CustomerProducerInterceptor implements ProducerInterceptor {      // 发送消息时,对消息拦截。     @Override     public ProducerRecord onSend(ProducerRecord producerRecord) {         System.out.println("拦截消息" + producerRecord.toString());         return null;     }      // 服务器是否收到了当前这条消息     @Override     public void onAcknowledgement(RecordMetadata recordMetadata, Exception e) {         if(recordMetadata != null){             System.out.println("服务器收到消息" + recordMetadata.offset());         }else{             // 没有收到消息发送失败             System.out.println("消息发送失败!!!");         }     }      @Override     public void close() {      }      @Override     public void configure(Map map) {      } } 

相关内容

热门资讯

透视ai!德普之星透视辅助软件... 透视ai!德普之星透视辅助软件激活码(透视)透视免费(有挂解密)1、全新机制【德普之星透视辅助软件激...
透视挂透视“wepoker亲友... 透视挂透视“wepoker亲友圈有用吗”wepoker俱乐部辅助(透视)有脚本(果然存在有挂)1、很...
透视工具!aapoker透视脚... 透视工具!aapoker透视脚本下载(透视)aapoker辅助工具安全吗,新2025教程(有挂解说)...
透视辅助“pokemmo手机版... 透视辅助“pokemmo手机版脚本”红龙poker辅助平台(透视)系统教程(确实真的有挂)1、红龙p...
透视软件!德扑圈有透视吗(透视... 透视软件!德扑圈有透视吗(透视)辅助软件(有挂规律);1、德扑圈有透视吗机器人多个强度级别选择2、德...
透视游戏“wepoker辅助器... 透视游戏“wepoker辅助器如何使用”wejoker辅助软件(透视)免费脚本咨询(真是存在有挂)1...
透视安装!aapoker如何设... 透视安装!aapoker如何设置胜率(透视)aa poker透视软件,扑克教程(有挂解说)aapok...
透视攻略“菠萝辅助器免费版的特... 透视攻略“菠萝辅助器免费版的特点”德州圈脚本(透视)2025教程(竟然是真的有挂)1、菠萝辅助器免费...
透视安装!德普辅助器辅助器怎么... 透视安装!德普辅助器辅助器怎么用(透视)辅助软件(有挂脚本)1、透视安装!德普辅助器辅助器怎么用(透...
透视app“wejoker辅助... 透视app“wejoker辅助软件视频”we-poker是什么软件(透视)破解是真的还是假的(好像有...