У меня есть несколько подпроектов в моем sbt, один из которых является сервером (на основе playframework), другой — клиентской стороной (scala.js), а третий — связью между ними в форме protobuf (scalapb). А это мой build.sbt : lazy val...

Я пытаюсь создать простую службу gRPC с помощью ScalaPB и Maven. Ниже приведена моя структура каталогов: ├── main │   ├── proto │   │   └── simple.proto │   ├── resources │   └── scala │   └── me │   ├── protogrpc │   │   └──...

У меня есть постоянный актер, который может получать команду одного типа Persist(event) , где событие имеет тип trait Event (существует множество его реализаций). И в случае успеха это возвращает Persisted(event) отправителю. Само событие...

Мое приложение Spark получает двоичные данные от Kafka. Данные отправляются в Kafka в виде байтового прото-сообщения. Прото-сообщение: message Any { string type_url=1; bytes value=2; } С помощью библиотеки ScalaPB я могу десериализовать...

Проект, над которым я работаю, находится на стадии планирования / прототипирования, и мы хотели бы передать наши данные в Spark 3, используя закодированные в протоколе protobuf сообщения в Kafka и структурированную потоковую передачу. Мы создали...