Я бы хотел зарегистрировать оба случая, когда сообщение было либо успешно опубликовано, либо по какой-то причине не удалось.
Из приведенных здесь примеров видно, что возможна только успешная регистрация https://doc.akka.io/docs/alpakka-kafka/current/producer.html
Я надеюсь, что подобный интерфейс также будет иметь сбои (возможно, запись об успешном / неуспешном вызове публикации как Either?), Чтобы регистрировать, произошел ли успех или сбой