Начинаю с Akka Streams и пока все идет хорошо. Однако я встречал вариант использования, к которому не знаю, как подойти. Сценарий представляет собой поток с ActorPublisher в качестве источника, который принимает сообщения от Kafka, и подписчиком в качестве приемника, который обновляет таблицу Cassandra.
Кафка ~> некоторые операции с отображением ~> Кассандра
Дело в том, что я хотел бы явно подтверждать Kafka каждый раз, когда сообщение было успешно обработано и вставлено в Cassandra, чтобы я мог перечитать сообщение в случае аварии и сбоя службы, т.е. после доставки поведение. Как я могу подойти к этому с точки зрения Akka Streams ?. Поддерживаемый сценарий ?.
Это правда, что я всегда могу настроить потребителя Kafka на автоматическую фиксацию, но я бы предпочел контролировать, как я читаю сообщения.
Обновить
Что касается этой темы, в настоящее время мы оцениваем Reactive Kafka, где они включили ручную фиксацию в kafka как версии 0.8 (спасибо этим ребятам). Эта функция позволит нам реализовать необходимое нам поведение.
