[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106558#comment-17106558
]
Matthias J. Sax commented on KAFKA-3184:
I am personally not sure how useful "local
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106046#comment-17106046
]
Nikolay Izhikov commented on KAFKA-3184:
[~guozhang] Thanks for the feedback and detailed
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105816#comment-17105816
]
Guozhang Wang commented on KAFKA-3184:
--
Hello [~nizhikov] for many state-light applications, it is
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099287#comment-17099287
]
Nikolay Izhikov commented on KAFKA-3184:
[~guozhang]
> we need to make the checkpointed offsets
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097581#comment-17097581
]
Matthias J. Sax commented on KAFKA-3184:
Works for me. But we can also discuss on the PR?
> Add
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097430#comment-17097430
]
Nikolay Izhikov commented on KAFKA-3184:
[~mjsax]
Can we use ".store" extension and "store file"
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096965#comment-17096965
]
Matthias J. Sax commented on KAFKA-3184:
[~guozhang] – from a naming perspective, we do have
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096718#comment-17096718
]
Nikolay Izhikov commented on KAFKA-3184:
Hello, [~guozhang]
I've prepared PR with the simplest
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736113#comment-16736113
]
Guozhang Wang commented on KAFKA-3184:
--
[~Yohan123] I think you are right: currently `persistent()`
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722380#comment-16722380
]
Richard Yu commented on KAFKA-3184:
---
As Ted pointed out, persistent() in {{InMemoryKeyValueStore}}
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701422#comment-16701422
]
Matthias J. Sax commented on KAFKA-3184:
Just a side comment: RocksDB allows to "pin/freeze" a
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344081#comment-16344081
]
Ted Yu commented on KAFKA-3184:
---
bq. only do the checkpointing every N. flush calls
This seems to be better
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16331348#comment-16331348
]
Guozhang Wang commented on KAFKA-3184:
--
[~yuzhih...@gmail.com] sorry for the late reply!
Your
13 matches
Mail list logo
