[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033915#comment-17033915 ] Sophie Blee-Goldman commented on KAFKA-9450: [~NaviBrar] I assume that was only merged into

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17025550#comment-17025550 ] Navinder Brar commented on KAFKA-9450: -- Checked Rocksdb code, event listeners are not available in

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17024902#comment-17024902 ] Navinder Brar commented on KAFKA-9450: -- Or do you suggest to never (ie, for EOS and non-EOS case)

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17024742#comment-17024742 ] Matthias J. Sax commented on KAFKA-9450: Yes, the ticket was created because the default EOS

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023643#comment-17023643 ] Navinder Brar commented on KAFKA-9450: -- Great that I caught hold of this Jira. I had been meaning to

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020489#comment-17020489 ] Matthias J. Sax commented on KAFKA-9450: For EOS, we don't write a checkpoint file, and thus we

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018781#comment-17018781 ] Guozhang Wang commented on KAFKA-9450: -- I think John's idea is to e.g. use a preserved key to store

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018750#comment-17018750 ] Matthias J. Sax commented on KAFKA-9450: [~vvcephei] Your comment seem to be an orthogonal

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018602#comment-17018602 ] Ted Yu commented on KAFKA-9450: --- w.r.t. separate column family, since the data in this family tends to be

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018501#comment-17018501 ] John Roesler commented on KAFKA-9450: - This reminds me of an idea I proposed a while back, and