...
We will introduce a new Public API class `StoreLagInfo` (inspired by HostInfo). The lag information would be computed by periodically (configurable) reading the record at the tail of the changelog, to obtain the timestamp for the ConsumerRecord. The
Code Block |
---|
package org.apache.kafka.streams; public class StoreLagInfo { // Estimate of number messages the store is behind by from the tail of the changelog private long messageLagEstimate; // Estimate of number of ms the store is behind from the tail of the changelog. private long timeLagEstimateMs; // Store name private String storeName; // Changelog topic partition ?? private TopicPartition topicPartition; ... // standard getters/setters will be added } |
...