kafka-tutorials

kafka-tutorials copied to clipboard

Describe the use case

You have a SaaS application and you want to understand how people use it with Google Analytics. Google Analytics is event-based. You send in JSON objects representing interesting stuff, and GA slices it either automatically or with some instruction.

You want your client (web browser, phone, etc) to be lightweight and not need to send large objects to GA every time. Yet you still need to send rich enough objects to GA to do analytics.

So you put ksqlDB in the middle between the browser and GA to do enrichment. Here, the enrichment can be pretty generic. The key is that you receive a stream of small events with some ID, and you join them on tables with data that needs to go for the ride. You can make up anything here: names, customer lifetime value, cohorts, whatever.

Provide the ksqlDB application Document the full set of ksqlDB statements that represent the use case.

N/A -- need to create ksqlDB code