Window Timestamps in KSQL / Integration with Elasticsearch
Read OriginalThis technical article details a change in how KSQL and Kafka Streams store window timestamps for aggregates, shifting from the window start time to the timestamp of the latest updating message. It provides a practical guide on accessing the window start time and configuring the Kafka Connect Elasticsearch sink to properly stream windowed aggregates for analysis and visualization in Kibana.
Comments
No comments yet
Be the first to share your thoughts!
Browser Extension
Get instant access to AllDevBlogs from your browser