Алпакка Акка стрим не может читать с кафки - PullRequest
Новая
       13

Алпакка Акка стрим не может читать с кафки

1 голос
/ 07 июня 2019

Я создал очень простой поток akka на основе проекта alpakka, но он ничего не читает из kafka, даже если он соединяется и создает группу потребителей.Я создал неявную систему Actor и Materializer для потока. 

val done = Consumer.committableSource(consumerSettings,
Subscriptions.topics(kafkaTopic))
.map(msg => msg.committableOffset)
.mapAsync(1) { offset =>
offset.commitScaladsl()
}
.runWith(Sink.ignore)
  • [stream.actor.dispatcher] отправляет это сообщение в KafkaConsumerActor "Запрос сообщений, requestId: 1, partitions: Set (kafka)-topic-0) "
  • Кажется, что KafkaConsumerActor не получает сообщение, но когда супервизор просит актера завершить работу, он получает сообщение и завершение работы.

Любой выводпочему не удается прочитать Кафку без ошибки или исключения?

1 Ответ

0 голосов
/ 17 июня 2019

Я не мог понять, почему мой поток akka не потреблял сообщения от брокера kafka, но когда я реализовал тот же поток, что и Runnable Graph, это сработало.

Примеры, которые я использовал - https://www.programcreek.com/scala/akka.stream.scaladsl.RunnableGraph

...