[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497934#comment-17497934
]
Matthias J. Sax commented on KAFKA-4212:
A windowed-store is basically just a `` kv-store and it
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497236#comment-17497236
]
Zhongda Zhao commented on KAFKA-4212:
-
We thought we could have used {{Materialized.withRetention}}
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913744#comment-16913744
]
Marcos Passos commented on KAFKA-4212:
--
We have the same requirement here at Croct.
> Add a
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910835#comment-16910835
]
Guozhang Wang commented on KAFKA-4212:
--
Hello James, I'd also recommend you checking if the FIFO
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910715#comment-16910715
]
Sophie Blee-Goldman commented on KAFKA-4212:
[~jamesritt] By the way, you might want to look
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910650#comment-16910650
]
James Ritt commented on KAFKA-4212:
---
Hi [~guozhang] thanks for input! In the comments above, most of us
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907548#comment-16907548
]
Guozhang Wang commented on KAFKA-4212:
--
Hello [~jamesritt] sorry for being late to this discussion,
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16901545#comment-16901545
]
James Ritt commented on KAFKA-4212:
---
Thanks [~ableegoldman] for spending your time with us on this!
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16901530#comment-16901530
]
ASF GitHub Bot commented on KAFKA-4212:
---
3rdLaw commented on pull request #7020: KAFKA-4212 &
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894823#comment-16894823
]
Sophie Blee-Goldman commented on KAFKA-4212:
Hey [~jamesritt]. I'm wondering if, rather than
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890580#comment-16890580
]
James Ritt commented on KAFKA-4212:
---
Hi [~ableegoldman] [~mjsax] [~guozhang] [~bbejeck] any further
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886605#comment-16886605
]
Steve Cosenza commented on KAFKA-4212:
--
For reference, Apache Samza supports RocksDB with TTL
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885498#comment-16885498
]
James Ritt commented on KAFKA-4212:
---
Thanks [~ableegoldman] & [~mjsax], you both make good points.
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882520#comment-16882520
]
Matthias J. Sax commented on KAFKA-4212:
I see. IMHO, we should not have a parameter for
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882516#comment-16882516
]
Sophie Blee-Goldman commented on KAFKA-4212:
Agreed, this wouldn't be possible within the
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882449#comment-16882449
]
James Ritt commented on KAFKA-4212:
---
Thanks [~ableegoldman] & [~mjsax]! So I took a look at
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880893#comment-16880893
]
Sophie Blee-Goldman commented on KAFKA-4212:
I agree with Matthias that, if we do want to go
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880761#comment-16880761
]
Matthias J. Sax commented on KAFKA-4212:
\cc [~guozhang] [~bbejeck] WDYT?
[~ctoomey]: just to
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880077#comment-16880077
]
Chris Toomey commented on KAFKA-4212:
-
[~mjsax] there are at least 3 different teams (I'm working
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16879569#comment-16879569
]
Matthias J. Sax commented on KAFKA-4212:
I agree about the application patterns and that it would
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878346#comment-16878346
]
Stanislav Savulchik commented on KAFKA-4212:
Hi, I'd like to describe an implementation that
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878060#comment-16878060
]
Del Bao commented on KAFKA-4212:
Our use case is even simpler. We just want to prevent local state store
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878027#comment-16878027
]
Elias Levy commented on KAFKA-4212:
---
I am the originator of the issue. And, yes, for our particular
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878024#comment-16878024
]
James Ritt commented on KAFKA-4212:
---
Hi [~mjsax], thanks for your input! I'm not the original
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876710#comment-16876710
]
Matthias J. Sax commented on KAFKA-4212:
Isn't RocksDB TTL based on wall-clock time? I think we
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876553#comment-16876553
]
James Ritt commented on KAFKA-4212:
---
Thanks [~ableegoldman]!
I definitely should have included more
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876516#comment-16876516
]
Sophie Blee-Goldman commented on KAFKA-4212:
Hi [~jamesritt], I think your PR is a good first
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876490#comment-16876490
]
James Ritt commented on KAFKA-4212:
---
So here is another attempt at this:
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876488#comment-16876488
]
ASF GitHub Bot commented on KAFKA-4212:
---
3rdLaw commented on pull request #7020: KAFKA-4212 &
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16850241#comment-16850241
]
Del Bao commented on KAFKA-4212:
vote for this. Windowed store makes the logic complex and confusing. At
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16821608#comment-16821608
]
Matthias J. Sax commented on KAFKA-4212:
If you configures topic cleanup policy as
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820644#comment-16820644
]
Chris Toomey commented on KAFKA-4212:
-
Our use case is we're using RocksDB as a key/value store cache
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16703737#comment-16703737
]
Matthias J. Sax commented on KAFKA-4212:
Ack
> Add a key-value store that is a TTL persistent
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702657#comment-16702657
]
Guozhang Wang commented on KAFKA-4212:
--
cc [~mjsax], I think you are already aware but there seems
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692424#comment-16692424
]
Adam Bellemare commented on KAFKA-4212:
---
We have some business requirements where we need to store
35 matches
Mail list logo