Как использовать фьючерсы в Kafka Streams - PullRequest
Новая
       4

Как использовать фьючерсы в Kafka Streams

1 голос
/ 11 февраля 2020

При использовании библиотеки org.apache.kafka.streams.KafkaStreams в Scala я пытался прочитать в inputStream, передать эту информацию методу: validateAll(infoToValidate), который возвращает Future, разрешить его и затем отправить в выходной поток ,

Пример: 

builder.stream[String, Object](REQUEST_TOPIC)
      .mapValues(v => ValidateFormat.from(v.asInstanceOf[GenericRecord]))
      .mapValues(infoToValidate => {
        SuccessFailFormat.to(validateAll(infoToValidate))
      })

Есть ли документация по выполнению этого? Я посмотрел на filter () и transform (), но все еще не уверен, как обращаться с Futures в KStreams.

...