[
https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691337#comment-16691337
]
Steven Aerts commented on KAFKA-7635:
-
To give you an idea a code change which we think might resolve
[
https://issues.apache.org/jira/browse/KAFKA-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-6567:
--
Assignee: Samuel Hawker (was: Yaswanth Kumar)
> KStreamWindowReduce can be replaced
[
https://issues.apache.org/jira/browse/KAFKA-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691247#comment-16691247
]
Matthias J. Sax commented on KAFKA-6567:
[~Samuel Hawker] Thanks for the PR. I added you to the
[
https://issues.apache.org/jira/browse/KAFKA-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691234#comment-16691234
]
Guozhang Wang commented on KAFKA-6567:
--
PR available here:
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691148#comment-16691148
]
Guozhang Wang commented on KAFKA-7610:
--
For 1), besides the code complexity I'm also a bit worried
[
https://issues.apache.org/jira/browse/KAFKA-7566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691145#comment-16691145
]
Guozhang Wang commented on KAFKA-7566:
--
[~bchen225242] could you elaborate a bit more on your use
[
https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691135#comment-16691135
]
Guozhang Wang commented on KAFKA-7634:
--
What I'd need to look at is the punctuate call inside your
[
https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691134#comment-16691134
]
Mark Tranter commented on KAFKA-7653:
-
Hi [~guozhang], thanks for your reply.
The issue is that
[
https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691128#comment-16691128
]
Guozhang Wang commented on KAFKA-7536:
--
Yeah I think so.
> TopologyTestDriver cannot pre-populate
[
https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691127#comment-16691127
]
Guozhang Wang commented on KAFKA-7653:
--
[~mark.tranter] I'm not sure I fully understand the issue
[
https://issues.apache.org/jira/browse/KAFKA-7523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691122#comment-16691122
]
Guozhang Wang edited comment on KAFKA-7523 at 11/18/18 11:06 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-7523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691122#comment-16691122
]
Guozhang Wang commented on KAFKA-7523:
--
[~pgwhalen] Sorry for being late on this. I think you have a
[
https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691113#comment-16691113
]
ASF GitHub Bot commented on KAFKA-7632:
---
dongjinleekr opened a new pull request #5927: KAFKA-7632:
[
https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691010#comment-16691010
]
Matthias J. Sax commented on KAFKA-7536:
Does this also affect 1.1.1 release? If yes, we should
[
https://issues.apache.org/jira/browse/KAFKA-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690983#comment-16690983
]
Junyu Chen commented on KAFKA-7062:
---
Oh did not realize that. I will check it out first. Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690978#comment-16690978
]
ASF GitHub Bot commented on KAFKA-7549:
---
dongjinleekr opened a new pull request #5925: KAFKA-7549:
[
https://issues.apache.org/jira/browse/KAFKA-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690883#comment-16690883
]
Andras Beni commented on KAFKA-7062:
[~Junyu Chen] Feel free to implement this change.
Note that
[
https://issues.apache.org/jira/browse/KAFKA-3362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andras Beni reassigned KAFKA-3362:
--
Assignee: (was: Andras Beni)
> Update protocol schema and field doc strings
>
[
https://issues.apache.org/jira/browse/KAFKA-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andras Beni reassigned KAFKA-6987:
--
Assignee: (was: Andras Beni)
> Reimplement KafkaFuture with CopletableFuture
>
[
https://issues.apache.org/jira/browse/KAFKA-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andras Beni reassigned KAFKA-7062:
--
Assignee: (was: Andras Beni)
> Simplify MirrorMaker loop after removal of old consumer
Mark Tranter created KAFKA-7653:
---
Summary: Streams-Scala: Add type level differentiation for Key and
Value serdes.
Key: KAFKA-7653
URL: https://issues.apache.org/jira/browse/KAFKA-7653
Project: Kafka
21 matches
Mail list logo