confluentinc / confluentinc/kafka-tutorials
LATEST_BY_OFFSET tutorial
Open
ksqlDB
recipe
- Dominant language
- Java
- Stars
- 39
- Forks
- 91
- PR merge metrics
- No merged PRs in 30d
Description
Community user wants to aggregate a stream of unique IP addresses from a topic not by window, but "by all time". Suggestion from Confluent streaming expert is to use CTAS with the `latest_by_offset` aggregation function. Create a tutorial showcasing how to use these two ksqlDB features together to answer the question...
"How do I table the latest values by key carrying forward all the record columns?"
https://confluentcommunity.slack.com/archives/C6UJNMY67/p1585687397143400
Contributor guide
Assessment
This issue has not been assessed yet.