I use embedded-kafka and I have some problems of stable work of it, reflected in:
Connection to node 0 (localhost/127.0.0.1:6001) could not be established. Broker may not be available. and timeouts.
I think that increase of memory can help, but I can't find any property for that. I tried to search code for memory or RAM words, but no luck. Is it possible to increase RAM for embedded-kafka?
There may be other issues also for this error, check the port and server properties.
I think you should increase the heap size of java process. which starts the embedded kafka.