ddcprg opened a new issue, #8773: URL: https://github.com/apache/pinot/issues/8773
As per the design document [Pinot Freshness Metric](https://cwiki.apache.org/confluence/display/PINOT/Pinot+Freshness+Metric), `minConsumingFreshnessTimeMs` should be calculated from row indexing timestamp if the stream provider doesn't provide row metadata. At the moment the default implementation returns null. This behaviour is not overwritten by out-of-the-box stream plugin implementations so indexing time is always chosen as `minConsumingFreshnessTimeMs` This issue is to implement row metadata for Kafka stream plugin 2.0 so `minConsumingFreshnessTimeMs` can be computed from the timestamp provided with Kafka `ConsumerRecord` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
