RabbitMQ Streams

• Streams : RabbitMQ 3.9 में नया जोड़ा गया डेटा स्ट्रक्चर

→ मौजूदा queue से अलग, यह messages को delete नहीं करने वाला Append-Only मॉडल है

→ डेटा बना रहता है और replicate होता है

• Usecase

→ जब कई applications को एक ही message एक साथ प्राप्त करना हो

→ बड़े पैमाने का backlog स्टोर करना

→ Timestamp के आधार पर replay और time travel संभव

→ मौजूदा queue की तुलना में बहुत तेज़

• मुख्य फीचर्स

→ कम-से-कम 1 बार delivery की गारंटी

→ server-side offset tracking सपोर्ट. Consumer अपनी इच्छित जगह से restart कर सकता है

→ अनंत रूप से scale किया जा सकता है. size/retention policy के आधार पर deletion सपोर्ट

→ अल्ट्रा-फास्ट समर्पित binary protocol तथा AMQP 0.91 & 1.0 सपोर्ट

→ client-server TLS सपोर्ट

→ Java / Client उपलब्ध

[xguru]

लगता है, जब Kafka की जगह छोटा‑मोटा stream processing करना हो तब इसे इस्तेमाल करने के लिए कहा जा रहा है।

Redis Streams और मौजूदा infra के हिसाब से ज़रूरत के मुताबिक चुन सकते हैं।

[galadbran]

ओ.. Kafka की तुलना में rabbitmq को install करना आसान है, तो यह अच्छा लगेगा!