Handle initial connection failure

[SukhikhN]

I start wolff producers during the app initialization with wolff:ensure_supervised_producers/3, but it fails if my kafka server is unavailable. I need to start them anyway so they will queue messages via replayq and replay the messages when connection will be established, just like when connection to kafka lost after app start.

Is there any way to achieve this with wolff?

I see that in previous versions producers were kept running after initial connection failure, but this commit https://github.com/kafka4beam/wolff/commit/e45b4ed9ff03d52ac23ef61beeba532ef5ba9a39 changed this behavior, and I don't fully understand why.