कफका घटना प्रणाली के रूप में

Question

यह प्रश्न Using Kafka as a (CQRS) Eventstore. Good idea? के समान है, लेकिन अधिक कार्यान्वयन विशिष्ट है। घटना स्टोर के रूप में काफ्का का उपयोग कैसे करें, जब मेरे पास हजारों कार्यक्रम "स्रोत" (डीडीडी में कुल जड़ों) हैं? जैसा कि मैंने लिंक किए गए प्रश्न और कुछ अन्य स्थानों में पढ़ा है, मुझे प्रति स्रोत विषय के साथ समस्याएं होगी। यदि मैं घटनाओं को विषयों के अनुसार विभाजित करता हूं, तो उपभोग और स्टोर करना बहुत आसान होगा, लेकिन मुझे विशेष स्रोत की ईवेंट स्ट्रीम तक पहुंच की आवश्यकता है। कफका के साथ सोर्सिंग कैसे करें?

Answer 1

अपने सभी ईवेंट स्रोतों को एक डेटा प्रकार (थ्रिफ्ट?) के साथ एक ही विषय पर पोस्ट करें जिसमें प्रत्येक ईवेंट स्रोत के लिए कुछ अद्वितीय पहचानकर्ता शामिल हैं। फिर उपभोक्ताओं को प्रत्येक ईवेंट प्रकार के लिए बनाएं जिसमें आप रुचि रखते हैं और प्रत्येक अद्वितीय उपभोक्ता समूह नाम के साथ पहचानें। इस तरह प्रत्येक अद्वितीय स्रोत उपभोक्ता के पास ज़ूकीपर में अपना ऑफसेट मूल्य होगा। प्रत्येक व्यक्ति पूरे विषय को पढ़ता है लेकिन केवल एक स्रोत (या स्रोतों के समूह) से जानकारी (या सौदों) को आउटपुट करता है।