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) {      } } 

相关内容

热门资讯

透视肯定!wepoker有人用... 透视肯定!wepoker有人用过吗,we poker插件(详细靠谱)在进入wepoker有人用过吗辅...
透视挂!wpk辅助插件,(wP... 透视挂!wpk辅助插件,(wPK)竟然是真的有挂(详细插件)该软件可以轻松地帮助玩家将wpk辅助插件...
透视最新!wepoker分析,... 透视最新!wepoker分析,wepoker挂(透视)真是是有挂1、构建自己的wepoker分析辅助...
透视好友房!德普之星有透视辅助... 透视好友房!德普之星有透视辅助吗(透视)辅助器(总是是有挂)德普之星有透视辅助吗是一种具有地方特色的...
透视教学!wpk俱乐部是做什么... 透视教学!wpk俱乐部是做什么的,(WPk)好像是有挂(详细微扑克微乐辅助);1、上手简单,内置详细...
透视最新!wepoker辅助软... 透视最新!wepoker辅助软件视频,we-poker有人玩吗(详细钻石可以看底牌);透视最新!we...
透视肯定!德普辅助器辅助器怎么... 透视肯定!德普辅助器辅助器怎么用(透视)辅助软件(果然存在有挂)1、德普辅助器辅助器怎么用ai机器人...
透视规律!wepoker俱乐部... 透视规律!wepoker俱乐部辅助,wepoker辅助器安装包定制(透视)一贯是有挂暗藏猫腻,小编详...
透视工具!wpk是真的还是假的... 透视工具!wpk是真的还是假的,(wpK)都是是有挂(详细透视辅助)1、不需要AI权限,帮助你快速的...
透视挂!wepoker作弊视频... 透视挂!wepoker作弊视频,wepoker有没有挂(详细可以增加运气)1、任何wepoker有没...