Исключение сериализации Akka Stream и умереть - PullRequest
Новая
       8

Исключение сериализации Akka Stream и умереть

0 голосов
/ 31 августа 2018

Я использую Kakfa-клиент с потоком Akka, и даже в моем материализаторе определена стратегия Supervisor 

    materializer = ActorMaterializer(createActorMaterializerSettings(strategyDecider, inputBuffer, system))
  private def createActorMaterializerSettings(strategyDecider: function.Function[Throwable, Supervision.Directive], inputBuffer: Int, system: ActorSystem) = {
    ActorMaterializerSettings(system)
      .withDispatcher("akka.stream-sink-dispatcher")
      .withSupervisionStrategy(toScalaFunction(strategyDecider))
      .withInputBuffer(initialSize = 1, maxSize = inputBuffer)
  }

Когда я получаю то, что не могу десериализовать 

akka stream die org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition

Мой поток не использует стратегию супервизора и не умирает.

Есть идеи, что здесь делать?

...