Emanuele Blanco

I think this could easily be addressed by adding a restart method. `.stop()` should clean up always, so I'd rather have a new method. Feel free to submit a PR...

if you try using `EmbeddedKafka.start()` and `.stop()` do you have the same result? I think the issue here is that there's an active connection while the server shuts down.

I'm thinking about possible implications of this on memory allocation during the build. It's definitely something that could be investigated - are you running them successfully?

Thanks @tjheslin1, seems like a sensible thing to do.

No worries @thrykol, I'm sorry this didn't fix the problem. Would you be able to submit a PR to fix this?

If you swap `localhost` with `127.0.0.1` what happens?

If you look at the post, the OP managed to fix it by adding the `advertised.port` property. You can add custom properties to brokers/producers/consumers by using the `EmbeddedKafkaConfig` class. Give...

Sorry to reply to this just now. Are you allowing parallel execution of your tests?

I'm sorry about this - I haven't been able to reproduce. What's the frequency of this failure? Could you share some of the test code you're talking about?

I wonder if this could actually be related to #150. Any chance you can try with the current `master`? If this is fixed I can release `1.1.1.1`.