Hendelsesstrømmer

Hendelsesstrømmer er sekvenser av hendelser som legges til i en vedvarende logg over tid for å registrere hva som skjer i et system. Hver hendelse beskriver en endring eller en observasjon, for eksempel at en bruker logger inn, at et kjøp gjennomføres, eller at en sensor rapporterer en verdi. Hendelser er ofte immutable og sorteres i tidsrekkefølge, noe som muliggjør gjenoppbygging av tilstander og sanntidsanalyse.

En typisk implementering består av produsenter som publiserer hendelser, en meldingsmegler eller lagringslagrer som holder hendelsene i emner (topics) og partisjoner, og konsumenter som leser hendelsene i sanntid eller senere. Hendelsesstrømmer brukes ofte i event-drevet arkitektur og i prosessering av strømmer.

Fysiske egenskaper inkluderer at loggen ofte er append-only, at levering kan være minst én gang eller eksplisitt én gang, og at rekkefølge kan være garantert innen en partisjon. Retensjonstiden bestemmer hvor lenge historiske hendelser lagres, og evnen til å lese og gjenta hendelser muliggjør audit og feilsøking.

Vanlige bruksområder er sanntidsanalyse og overvåking, integrasjon mellom systemer, og hendelsessourcing der hele forandringer i et domene bygges opp fra hendelser.

Vanlige teknologier inkluderer Apache Kafka, Apache Pulsar, AWS Kinesis og Google Pub/Sub. Disse plattformene tilbyr ulike modeller for lagring, partisjonering, feilhåndtering og schema-styring, og påvirker hvordan man designer produsenter og konsumenter.

Utfordringer i design av hendelsesstrømmer omfatter schema-evolusjon, backpressure, skalerbarhet, data governance og sikkerhet, samt å sikre korrekt idempotent behandling og enkel gjenlesing av historiske hendelser.