Цепочка Akka Streams Kafka с Akka-http от источника [Bytestring]

Я получаю файл в виде строки байтов от потребителя Kafka Reactive Streams, который я хочу отправить в службу.

Есть ли возможность извлечь Source[Bytestring, Any] из Kafka Reactive Stream Consumer, чтобы я мог связать поток от Kafka до Akka-http, не загружая в память всю строку Bytestring, а затем выполняя запрос akka-http?

0 ответов

Другие вопросы по тегам