-
0 votesanswersviews
如何将akka streams kafka(reactive-kafka)集成到akka http应用程序中?
我有一个基本的scala akka http CRUD应用程序 . 请参阅下面的相关课程 . 我只想将实体id和一些数据(作为json)写入Kafka主题,例如,创建/更新实体 . 我正在看http://doc.akka.io/docs/akka-stream-kafka/current/producer.html,但我是scala和akka的新手,并且不确定如何将它集成到我的应用程序中? 例如,... -
1 votesanswersviews
如何在Akka Streams Kafka中构建ProducerMessage时配置偏移参数?
我正在使用Scala 2.11和Akka Streams Kafka 0.17 . 我有 stream 其中: A Source 使用Source.actorRef创建 . 这里,actor被安排以一定的间隔运行并连续生成消息,这些消息被发送到流 . 我已将 Producer 附加为 Flow . 制作人将 ProducerMessage.Message 推送到Kafka主题 . ...