~/talk

Building a Distributed Data Ingestion System with RabbitMQ

Talkat Scala.IO 2014 · 2014-10-23..10-24· [microservices, databases]
slides:none on file

A concrete recipe for sending global telemetry: RabbitMQ plus the Federation plugin replicates exchanges and queues transparently so apps need no code changes, and sharding uses a router to split traffic across nodes. The talk shows a working simulator and basic‑Q demo (500 messages, prefetch 5, 4 consumers) and explains tradeoffs — sharded queues partition by consistent hash and you tune replication with configurable max_hops message_ttl prefetch_count to avoid local buffer bloat.

AI-written summary · about

  1. 0:00Introduction
  2. 1:13Paris
  3. 6:20Java
  4. 6:37Java Client
  5. 10:18Messaging
  6. 17:03Graphics
  7. 17:53Sending data
  8. 22:08Unbound local buffer
  9. 23:38Federation
  10. 27:48Configuration
  11. 30:03Quality of Service
  12. 31:58BasicQueue Simulator
  13. 34:08Queueing Theory
  14. 36:43Scheduling and Queue
  15. 41:58Partition
~/search
type to search 6,249 conferences, 138,987 speakers and 185,172 talks
~/help
cmdctrl k
search every conference, speaker and series
/
focus the filter search
h
home
c
conferences
s
speakers
e
series
t
light / dark — the status bar button does the same
?
this help
esc
close this, then clear every filter — or just the search, while you are typing in it

Ignored while you are typing. Pages without a filter rail have no search to focus.