我使用embedded-kafka,并且在稳定工作方面存在一些问题,体现在:Connection to node 0 (localhost/127.0.0.1:6001) could not be established. Broker may not be available.
和超时。
我认为增加内存可以有所帮助,但是我找不到任何属性。我尝试搜索memory
或RAM
单词的代码,但是没有运气。是否可以为嵌入式kafka增加RAM?
此错误也可能存在其他问题,请检查端口和服务器属性。我认为您应该增加Java进程的堆大小。这将启动嵌入式kafka。