Graceful shutdown in KafkaActorPublisher about alpakka-kafka HOT 5 CLOSED

That was my idea a while ago, but unfortunately postStop() also gets called on actor restart and the problem is that after a KafkaActorPublisher gets restarted, it is impossible to revive its inner consumer. However, I'm also quite bothered by the way that we need to handle shutdowns with current API (the way you mentioned or by DeathWatch). Let's keep this issue open and look for some solution.

from alpakka-kafka.

We'll keep working on this. By the way, I hadn't thought in dead watching for this and maybe could work better than cancelling in our case. Thanks for that!.

from alpakka-kafka.

Hi,

are there any new approaches towards gracefully shutting down the publisher?

Jan

from alpakka-kafka.

@algermissen 0.8.3 uses onErrorThenStop(ex), so in case of exception the publisher will be automatically closed. I'm working on the README to explain this, I guess this issue can be closed.

from alpakka-kafka.

Thanks @kciesielski, I'll check this out. Closing the ticket.

from alpakka-kafka.