Event Streaming

Event streaming, bir sistemde olan her şeyi, örneğin bir tıklamayı, bir ödemeyi, bir sensör okumasını ya da bir veritabanı değişikliğini bir olay (event) olarak ele alır ve bu olayları gerçekleştikçe sırayla kaydeder. Olaylar kalıcı, yalnızca eklemeli (append-only) bir logda tutulur ve istediği sayıda uygulama bu logu, ya olaylar geldiği anda ya da daha sonra, geçmişin herhangi bir noktasından okuyabilir.

Apache Kafka ve Apache Pulsar gibi platformlar olayları konulara (topic) düzenler; konular sunuculara yayılabilmesi ve paralel işlenebilmesi için bölümlere (partition) ayrılır. Sıra bir bölüm içinde garanti edilir; bu yüzden bir müşterinin kimliği gibi aynı anahtara sahip olaylar sırada kalır. Her tüketici logdaki kendi konumunu, yani offset'i izler. Bu sayede yeni bir servis baştan başlayıp aylarca geçmişi yeniden oynatabilir, hatalı bir tüketici de geri sarıp yeniden işleyebilir. Olaylar okunduktan sonra silinmek yerine, yapılandırılmış bir saklama süresi boyunca (saatlerden sonsuza kadar) tutulur.

Event streaming, kapı zili yerine güvenlik kamerası kaydına benzer: kapı zili yalnızca o anda evde olan kişiyi uyarır; bir kayıt ise ihtiyacı olan herkes tarafından canlı izlenebilir ya da sonra geri sarılabilir. Gerçek zamanlı analitikte, sahtekârlık tespitinde, etkinlik takibinde, change data capture yoluyla veritabanları ile veri ambarları arasında veri kopyalamada ve olay güdümlü mimaride mikroservisleri bağlamada kullanılır. Kafka Streams ve Apache Flink gibi akış işleme araçları, olaylar akarken onları filtrelemek, birleştirmek ve toplamak için akışları sürekli okur.

Event streaming sıklıkla mesaj kuyrukları ve event sourcing ile karıştırılır. Geleneksel bir mesaj kuyruğu, bir tüketici onayladığında mesajı siler ve her mesaj tek bir worker'a gider; bir olay akışı ise olayları saklar, böylece birçok tüketici onları bağımsız okuyabilir ve yeniden oynatabilir. Event sourcing, bir uygulamanın durumunu onu üreten olaylar dizisi olarak sakladığı bir mimari kalıptır; çoğu zaman bir olay logu kullanır, ancak event streaming olayları bütün bir kurumda taşımak ve işlemek için daha geniş altyapıdır.