胡Ba一.ˇ°

0 声望

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

个人动态

无心 SpringBoot整合Kafka(开启SSL状态报错不开启SSL可以正常使用) 项目启动报错Java heap space 发表评论:
看样子大概率是 SSL的问题。 https://stackoverflow.com/questions/58218493/kafka-and-ssl-java-lang-outofmemoryerror-java-heap-space-when-using-kafka-top 看下 kafka Server.log 就会发现 SSL认证失败。 猜测原因是 SSL 认证失败, 数据始终没有发送出去, 最后 OOM。 希望对其他人有所帮助。
14天前
半兽人 关注了Ta · 8月前
胡Ba一.ˇ° 回复 半兽人 SpringBoot整合Kafka(开启SSL状态报错不开启SSL可以正常使用) 项目启动报错Java heap space 中 :
这个代码不开ssl就可以跑通,开了就报异常...
1年前
胡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(); }
1年前
发表了 springboot整合kafka  
1年前
关注了用户 半兽人 · 1年前

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