Dear experts,
Could you please let me know whether any akka based design pattern is there to ensure ordering while injecting messages to kafka in the following scenario . * TCP stream * * framing and parsing * *message formation * * kafka* Network events-------------------------> Netty-------------------------------------->AkkaPre-Processor---------------------------------------> kafka producer==================kafkaConsumer 1. Events are generated by hardware which controls the manufacturing plant. 2. Events are send using raw TCP stream 3. Netty listens for TCP stream , does framing and basic parsing.Quickly posts message to an actor. 4. Actor does heavy preprocessing,create a readable message and send to kafka producer. Challenge: If I spawn transient actors for processing each messages , I will get concurrency and leave netty free. But I cannot ensure ordering of messages based on time@which network events are generated. Is there a pattern using which I could ensure ordering in such scenario. regards Mahesh -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.