[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531353#comment-15531353
]
Elias Levy commented on KAFKA-4212:
---
I am using the {{KStream.transform}} API, the {{Transform}}
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531263#comment-15531263
]
Guozhang Wang commented on KAFKA-4212:
--
Ah I thought you are trying to apply the lower-level
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531116#comment-15531116
]
Elias Levy commented on KAFKA-4212:
---
But joins are not performed on hopping windows, they are performed
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531077#comment-15531077
]
Guozhang Wang commented on KAFKA-4212:
--
When creating the windowed store with
{code}
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531022#comment-15531022
]
Elias Levy commented on KAFKA-4212:
---
Not sure I follow.
> Add a key-value store that is a TTL
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15530995#comment-15530995
]
Elias Levy commented on KAFKA-4212:
---
I would described it as a TTL, not LRU. We want the records to
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15530909#comment-15530909
]
Guozhang Wang commented on KAFKA-4212:
--
Thanks for the detailed description Elias, I think a
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15530904#comment-15530904
]
Guozhang Wang commented on KAFKA-4212:
--
Records within the same window with the same key will
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527841#comment-15527841
]
Elias Levy commented on KAFKA-4212:
---
Looks like using {{WindowStore}} is not quite so simple, as you
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15524513#comment-15524513
]
Elias Levy commented on KAFKA-4212:
---
More generally, the use case is: I've told a bunch of folks about
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15524402#comment-15524402
]
Elias Levy commented on KAFKA-4212:
---
The general use case is the joining of updates to two tables over a
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15524186#comment-15524186
]
Guozhang Wang commented on KAFKA-4212:
--
Hello [~elevy], thanks for reporting this feature request.
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15521287#comment-15521287
]
Elias Levy commented on KAFKA-4212:
---
I should be noted that a variable-capacity memory-overflowing TTL
13 matches
Mail list logo
