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