[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693778#comment-16693778
]
Matthias J. Sax commented on KAFKA-7577:
Glad to hear. We have a ticket KAFKA-7658 to add
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693770#comment-16693770
]
Daren Thomas commented on KAFKA-7577:
-
Yes, thank you, that does make sense. I verified (in a
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692535#comment-16692535
]
Matthias J. Sax commented on KAFKA-7577:
An `aggregation()` is designed like in SQL, that also
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692143#comment-16692143
]
Daren Thomas commented on KAFKA-7577:
-
This is the detailed behavior of KGroupedTable:
* When a
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692136#comment-16692136
]
Daren Thomas commented on KAFKA-7577:
-
What is the reasoning behind that being the design?
I'm
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692066#comment-16692066
]
Matthias J. Sax commented on KAFKA-7577:
`aggregate()` will drop any `null`-value input record as
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691821#comment-16691821
]
Daren Thomas commented on KAFKA-7577:
-
[~guozhang] I have unit tests for the issue, but not ones I
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690175#comment-16690175
]
Guozhang Wang commented on KAFKA-7577:
--
Hi [~dthomas-trimble], any luck trying to reproduce the
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16673444#comment-16673444
]
Matthias J. Sax commented on KAFKA-7577:
TopologyTestDriver docs:
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16673137#comment-16673137
]
Daren Thomas commented on KAFKA-7577:
-
{quote}Can you verify that Y.leftJoin(Z) produces an output
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672341#comment-16672341
]
Matthias J. Sax commented on KAFKA-7577:
Thanks for clarification. Still try to understand the
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672245#comment-16672245
]
Daren Thomas commented on KAFKA-7577:
-
{quote}Note, that a tombstone message is only produced, if
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1667#comment-1667
]
Matthias J. Sax commented on KAFKA-7577:
Can you describe your test data your are using and your
[
https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671844#comment-16671844
]
Daren Thomas commented on KAFKA-7577:
-
I see similar behavior with the right side of the Left Join.
14 matches
Mail list logo