scala - 如何增加嵌入式 kafka 的 RAM？

Question

我使用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？

Answer 1

此错误可能还有其他问题，请检查端口和服务器属性。
我认为你应该增加java进程的堆大小。这将启动嵌入式 kafka。