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 [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
