Hi all, So I have a problem I cannot find out how to solve.
I have a flow that receives many elements, and as I have to access a db with that data, I have to group them so I query the db once instead of 1000 times: deleteActivityFlow.grouped(1000) The problem is that after doing all the processing required, I end up with a Seq[String] that represent the domain event in a json format I have to push to the kafka Sink: Sink(kafka.publish(producerProperties)) This sink expects a String, not a Seq[String], so I was wondering if there's any way of achieving this grouped(1000) inverse Thanks in advance! -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
