胡Ba一.ˇ°

0 声望

这家伙太懒,什么都没留下

个人动态

半兽人 关注了Ta · 1月前
胡Ba一.ˇ° 回复 半兽人 SpringBoot整合Kafka(开启SSL状态报错不开启SSL可以正常使用) 项目启动报错Java heap space 中 :
这个代码不开ssl就可以跑通,开了就报异常...
6月前
胡Ba一.ˇ° 回复 半兽人 SpringBoot整合Kafka(开启SSL状态报错不开启SSL可以正常使用) 项目启动报错Java heap space 中 :
Producer代码 @RequestMapping("/send") public String sendMessage(){ String msg="producer"; ListenableFuture test = kafkaTemplate.send(topic,msg); test.addCallback(new ListenableFutureCallback() { @Override public void onFailure(Throwable throwable) { System.out.println("发送失败"); } @Override public void onSuccess(Object o) { System.out.println("发送成功"); } }); return "success"; } Consumer代码 @KafkaListener(topics = "${pro.topic2}", groupId = "${spring.kafka.consumer.group-id}", containerFactory = "kafkaListenerContainerFactory", errorHandler = "consumerAwareErrorHandler") public void listen2(ConsumerRecord consumerRecord, Acknowledgment acknowledgment) { System.out.println("testInQT====key======" + consumerRecord.key() + "=====Value===" + consumerRecord.value() + "=====offset=====" + consumerRecord.offset() + "consumerRecord.partition();" + consumerRecord.partition()); acknowledgment.acknowledge(); }
6月前
半兽人 回复 胡Ba一.ˇ° SpringBoot整合Kafka(开启SSL状态报错不开启SSL可以正常使用) 项目启动报错Java heap space 中 :
有毒。你是不是死循环了,内存有多少吃多少。
6月前
发表了 springboot整合kafka  
11月前
关注了用户 半兽人 · 1年前

(゚∀゚ )
暂时没有任何数据