I’m working with alpakka (slick,cassandra,kafka).
For consuming a Kafka topic I use the Draining Control combined with the new Committer Sink.
Thats nice, but I’m unsure how I can now react (restart) on errors that probably after not existing anymore after a restart (connection problems, …).
I would like to use the RestartSource but a DrainingControl is not a Source or CompletionStage.
Whats the trick?