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更新快且高清...
每日必看!智星德州菠萝外挂检测... 每日必看!智星德州菠萝外挂检测(辅助挂)软件透明挂(有挂教学)-哔哩哔哩1、玩家可以在智星德州菠萝外...
透视透明挂!轰趴十三水有后台(... 轰趴十三水有后台赢率提升策略‌;透视透明挂!轰趴十三水有后台(辅助挂)软件透明挂(有挂详情)-哔哩哔...
发现玩家!德扑ai助手软件(辅... 发现玩家!德扑ai助手软件(辅助挂)透视辅助(有挂教学)-哔哩哔哩;玩家在德扑ai助手软件中需先进行...
一分钟了解!x-poker辅助... 一分钟了解!x-poker辅助软件(辅助挂)辅助透视(有挂攻略)-哔哩哔哩1、每一步都需要思考,不同...
一分钟揭秘!德州最新辅助器(辅... 一分钟揭秘!德州最新辅助器(辅助挂)透视辅助(有挂攻略)-哔哩哔哩;德州最新辅助器最新版本免费下载安...
玩家攻略推荐!德州辅助(辅助挂... 玩家攻略推荐!德州辅助(辅助挂)辅助透视(有挂了解)-哔哩哔哩是由北京得德州辅助黑科技有限公司精心研...
揭秘真相!pokernow德州... 《揭秘真相!pokernow德州(辅助挂)辅助透视(有挂介绍)-哔哩哔哩》 pokernow德州软件...
五分钟了解!德州之星辅助器(辅... 五分钟了解!德州之星辅助器(辅助挂)辅助透视(有挂透明)-哔哩哔哩1、很好的工具软件,可以解锁游戏的...
推荐一款!pokermaste... 1、推荐一款!pokermaster有外挂(辅助挂)透视辅助(有挂教学)-哔哩哔哩;详细教程。2、p...