Я бы хотел использовать Alpakka Kafka Connector для записи в тему Kafka из приложения, созданного в Scala.
Возврат из записи выглядит как Future[Done],Тем не менее, я думаю, что как только запись произошла (и я хочу быть уверенной в этом), также известно смещение, используемое при чтении темы.Как писатель может получить это?
Я хотел бы использовать сгенерированные автоматически смещения, а не поддерживать свои собственные.Авторов может быть много (это еще одна причина для использования автоматически сгенерированных).Причина, по которой нужно увидеть смещение, заключается в том, что тогда я могу позволить своим вызывающим абонентам проверить, когда они действительно видят эту запись на стороне чтения.
Может быть, это невозможно?