[
https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-7994:
---
Description:
We compute a per-partition partition-time as the maximum timestamp over
[
https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Richard Yu updated KAFKA-7994:
--
Description:
We compute a per-partition partition-time as the maximum timestamp over all
records proce
[
https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Richard Yu updated KAFKA-7994:
--
Description:
We compute a per-partition partition-time as the maximum timestamp over all
records proce
[
https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Richard Yu updated KAFKA-7994:
--
Attachment: possible-patch.diff
> Improve Stream-Time for rebalances and restarts
> ---