Concepts

When implementing stream processing in the large, we should consider

• Scalablity
• Concurrency/Partitioning
• Fault tolerance Message delivery semantics à la
  • at-most-once
  • at-least-once
  • exactly-once
• Message patterns
  • Request-Response
  • Publish-Subscribe
• Reprocessing/Replay
• Performance(latency and throughput)