THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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
} |
...