We're sorry but this page doesn't work properly without JavaScript enabled. Please enable it to continue.
Feedback

Min and Max Aggregations with Updates in Real Time

Formal Metadata

Title
Min and Max Aggregations with Updates in Real Time
Title of Series
Number of Parts
56
Author
Contributors
License
CC Attribution 3.0 Unported:
You are free to use, adapt and copy, distribute and transmit the work or content in adapted or unchanged form for any legal purpose as long as the work is attributed to the author in the manner specified by the author or licensor.
Identifiers
Publisher
Release Date
Language

Content Metadata

Subject Area
Genre
Abstract
As part of our analytics platform we handle real time ingestion and aggregations by performing aggregations such as count and sum based on roll ups such as day, hour and minute using Kafka streams app. We recently added support for Min and Max measures along with existing sum and count while performing aggregations on incoming Kafka records. The interesting part is that we also support all these aggregations on Updated records. This talk aims at exploring the interesting details that went into adding the Min and Max functionality to our Kafka streams app while performing real-time aggregations with Updates.