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

相关内容

热门资讯

解密关于!中至上饶小程序有挂吗... 解密关于!中至上饶小程序有挂吗(透视)透视辅助工具(2024已更新)(哔哩哔哩)一、中至上饶小程序有...
二分钟实锤!财神13张刷低胜率... 二分钟实锤!财神13张刷低胜率,wEPOKE真是存在有挂,透牌教程(有挂实操)暗藏猫腻,小编详细说明...
科技分享!哥哥杭州麻将有挂吗(... 科技分享!哥哥杭州麻将有挂吗(透明挂)总是存在有挂(2025已更新)(哔哩哔哩)哥哥杭州麻将有挂吗辅...
11分钟辅助挂!钱塘13水打牌... 1、11分钟辅助挂!钱塘13水打牌“详细透视辅助助手教程”原来真的有挂;详细教程。2、钱塘13水打牌...
终于清楚!桃乐互娱有没有外 挂... 终于清楚!桃乐互娱有没有外 挂(透视辅助)外挂透明挂辅助脚本(2020已更新)(哔哩哔哩)桃乐互娱有...
3分钟辅助!老友麻将有挂吗,菠... 3分钟辅助!老友麻将有挂吗,菠萝德州一贯真的有挂,技巧教程(有挂教程)1、完成老友麻将有挂吗透视辅助...
分辨真假!哈局十三张(辅助)其... 分辨真假!哈局十三张(辅助)其实是真的有挂(2021已更新)(哔哩哔哩)1、进入到哈局十三张黑科技之...
16分钟辅助挂!胡乐麻将辅牌器... 16分钟辅助挂!胡乐麻将辅牌器“详细透视辅助app教程”原来真的有挂是一款可以让一直输的玩家,快速成...
推荐一款!!乐清同城游麻将是不... 推荐一款!!乐清同城游麻将是不是有挂(透视)透明挂透视辅助插件(2022已更新)(哔哩哔哩)1、很好...
一分钟辅助挂!闲逸游戏有控制牌... 一分钟辅助挂!闲逸游戏有控制牌的软件吗,xpoker果然真的有挂,玩家教程(有挂细节);闲逸游戏有控...