[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820083#comment-17820083 ] Jinyong Choi commented on KAFKA-15302: -- [~cervinka]  Hi. It seems like the patch for this issue

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818755#comment-17818755 ] Ondrej Cervinka commented on KAFKA-15302: - Hello, Deleting from a state store while iterating

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756245#comment-17756245 ] Jinyong Choi commented on KAFKA-15302: -- I got it. > Stale value returned when using store.all() in

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755298#comment-17755298 ] Matthias J. Sax commented on KAFKA-15302: - I would need to think more about this. Overall, it

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753490#comment-17753490 ] Jinyong Choi commented on KAFKA-15302: -- [~mjsax] [~guozhang]  I had a new idea. The essence of

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752451#comment-17752451 ] Jinyong Choi commented on KAFKA-15302: -- [~mjsax] , [~guozhang]    If you perform a delete() within

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751836#comment-17751836 ] Matthias J. Sax commented on KAFKA-15302: - {quote}it's a combo of a cache snapshot and the

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751830#comment-17751830 ] Guozhang Wang commented on KAFKA-15302: --- I think case I'm not sure if this is defined as a bug

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751761#comment-17751761 ] Matthias J. Sax commented on KAFKA-15302: - Thanks for providing more details; the `delete()`

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751422#comment-17751422 ] Jinyong Choi commented on KAFKA-15302: -- [~guozhang] Hi. Sure. It is my test code. As you

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751403#comment-17751403 ] Guozhang Wang commented on KAFKA-15302: --- [~jinyong.choi] to help us better understand your issue,

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751323#comment-17751323 ] Jinyong Choi commented on KAFKA-15302: -- Hi Matthias J. Sax, Reading your comment helped me to be

[jira] [Commented] (KAFKA-15302) Stale value returned when using store.all() in punctuation function.

[ https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751236#comment-17751236 ] Matthias J. Sax commented on KAFKA-15302: - Thanks for reporting this issue. – When you call