[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725357#comment-17725357
]
Matthias J. Sax commented on KAFKA-7497:
Seems to be fixed. Cf
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552538#comment-17552538
]
Rohit Verma commented on KAFKA-7497:
In fact, our use case is also for multiple events on the same
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17396307#comment-17396307
]
Matthias J. Sax commented on KAFKA-7497:
Given my above comment:
{quote}Also, and this seems to
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743468#comment-16743468
]
Guozhang Wang commented on KAFKA-7497:
--
>From the expressiveness of the operators, I think there are
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743329#comment-16743329
]
John Roesler commented on KAFKA-7497:
-
Ah. I was looking at the javadoc on `KStream#join`. My bad.
>
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743249#comment-16743249
]
Matthias J. Sax commented on KAFKA-7497:
You understanding seems correct. Also not the JavaDocs
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743225#comment-16743225
]
John Roesler commented on KAFKA-7497:
-
Thanks [~mjsax],
I see that the "key" field in Kafka can be
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742733#comment-16742733
]
Matthias J. Sax commented on KAFKA-7497:
I disagree "that you have a stream of unique events" –
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742729#comment-16742729
]
John Roesler commented on KAFKA-7497:
-
Note, the use-case reference above is now at:
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16648105#comment-16648105
]
Guozhang Wang commented on KAFKA-7497:
--
[~mjsax] You're right, I was only thinking about the use
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647671#comment-16647671
]
Robin Moffatt commented on KAFKA-7497:
--
Here's the use case, inspecting a stream of transactions
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647138#comment-16647138
]
Matthias J. Sax commented on KAFKA-7497:
[~guozhang] I cannot follow? A self-join would still
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647044#comment-16647044
]
Guozhang Wang commented on KAFKA-7497:
--
[~rmoff] Before we dive into the implementation details,
[
https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646892#comment-16646892
]
Matthias J. Sax commented on KAFKA-7497:
It is correct, that a topic cannot be consumed twice
14 matches
Mail list logo