persistenceId: String,
sequenceNr: Long) = {
val CustomerInfo: CustomerUpdated[_] =???
elasticClient.execute {
indexInto(s"$indexName" / s"$indexName")
.doc(CustomerInfo)
.id(persistenceId)
}
Сделайте Source для своих событий и присоедените его к
Обсуждают сегодня