[jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

2018-11-18 Thread Steven Aerts (JIRA)
[ 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

[jira] [Assigned] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate

2018-11-18 Thread Matthias J. Sax (JIRA)
[ 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

[jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate

2018-11-18 Thread Matthias J. Sax (JIRA)
[ 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

[jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate

2018-11-18 Thread Guozhang Wang (JIRA)
[ 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:

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-18 Thread Guozhang Wang (JIRA)
[ 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

[jira] [Commented] (KAFKA-7566) Add sidecar job to leader (or a random single follower) only

2018-11-18 Thread Guozhang Wang (JIRA)
[ 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

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

2018-11-18 Thread Guozhang Wang (JIRA)
[ 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

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

2018-11-18 Thread Mark Tranter (JIRA)
[ 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

[jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable or GlobalKTable

2018-11-18 Thread Guozhang Wang (JIRA)
[ 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

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

2018-11-18 Thread Guozhang Wang (JIRA)
[ 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

[jira] [Comment Edited] (KAFKA-7523) TransformerSupplier/ProcessorSupplier enhancements

2018-11-18 Thread Guozhang Wang (JIRA)
[ 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: -

[jira] [Commented] (KAFKA-7523) TransformerSupplier/ProcessorSupplier enhancements

2018-11-18 Thread Guozhang Wang (JIRA)
[ 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

[jira] [Commented] (KAFKA-7632) Add producer option to adjust compression level

2018-11-18 Thread ASF GitHub Bot (JIRA)
[ 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:

[jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable or GlobalKTable

2018-11-18 Thread Matthias J. Sax (JIRA)
[ 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

[jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support

2018-11-18 Thread Junyu Chen (JIRA)
[ 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

[jira] [Commented] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client

2018-11-18 Thread ASF GitHub Bot (JIRA)
[ 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:

[jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support

2018-11-18 Thread Andras Beni (JIRA)
[ 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

[jira] [Assigned] (KAFKA-3362) Update protocol schema and field doc strings

2018-11-18 Thread Andras Beni (JIRA)
[ 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 >

[jira] [Assigned] (KAFKA-6987) Reimplement KafkaFuture with CopletableFuture

2018-11-18 Thread Andras Beni (JIRA)
[ 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 >

[jira] [Assigned] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support

2018-11-18 Thread Andras Beni (JIRA)
[ 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

[jira] [Created] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

2018-11-18 Thread Mark Tranter (JIRA)
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