[
https://issues.apache.org/jira/browse/KAFKA-2592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14933650#comment-14933650
]
Guozhang Wang commented on KAFKA-2592:
--
The problem is that when we flush the rocksDB / change-log,
[
https://issues.apache.org/jira/browse/KAFKA-2592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14933603#comment-14933603
]
Jay Kreps commented on KAFKA-2592:
--
I think the impl strategy that Samza has is pretty good, it keeps an
[
https://issues.apache.org/jira/browse/KAFKA-2592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14933694#comment-14933694
]
Guozhang Wang commented on KAFKA-2592:
--
Yes, this is not a correctness issue since we do not have
[
https://issues.apache.org/jira/browse/KAFKA-2592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14933673#comment-14933673
]
Jay Kreps commented on KAFKA-2592:
--
That is generally true for all output, though, right? Not more true
