[jira] [Commented] (KAFKA-6740) Plugins class' newConverter and newHeaderConverter methods are unclear

2018-04-02 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423499#comment-16423499 ] Randall Hauch commented on KAFKA-6740: -- These methods could be done much more cleanly with Java 8 and

[jira] [Created] (KAFKA-6740) Plugins class' newConverter and newHeaderConverter methods are unclear

2018-04-02 Thread Randall Hauch (JIRA)
Randall Hauch created KAFKA-6740: Summary: Plugins class' newConverter and newHeaderConverter methods are unclear Key: KAFKA-6740 URL: https://issues.apache.org/jira/browse/KAFKA-6740 Project: Kafka

[jira] [Commented] (KAFKA-6740) Plugins class' newConverter and newHeaderConverter methods are unclear

2018-04-02 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423496#comment-16423496 ] Randall Hauch commented on KAFKA-6740: -- See an earlier fix to these methods. > Plugins class'

[jira] [Commented] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423455#comment-16423455 ] ASF GitHub Bot commented on KAFKA-6728: --- tedyu closed pull request #4800: KAFKA-6728 Kafka Connect

[jira] [Commented] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-02 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423452#comment-16423452 ] Randall Hauch commented on KAFKA-6728: -- Testing with a test source connector reveals the same

[jira] [Commented] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-02 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423380#comment-16423380 ] Randall Hauch commented on KAFKA-6728: -- Added a second PR (see previous message) that attempts to fix

[jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

2018-04-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423359#comment-16423359 ] ASF GitHub Bot commented on KAFKA-6054: --- mjsax closed pull request #4768: KAFKA-6054: Fix upgrade

[jira] [Commented] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423358#comment-16423358 ] ASF GitHub Bot commented on KAFKA-6728: --- rhauch opened a new pull request #4815: [WIP] KAFKA-6728:

[jira] [Commented] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

2018-04-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423341#comment-16423341 ] ASF GitHub Bot commented on KAFKA-6560: --- guozhangwang opened a new pull request #4814: KAFKA-6560:

[jira] [Commented] (KAFKA-6739) Broker receives error when handling request with java.lang.IllegalArgumentException: Magic v0 does not support record headers

2018-04-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423302#comment-16423302 ] ASF GitHub Bot commented on KAFKA-6739: --- dhruvilshah3 opened a new pull request #4813: KAFKA-6739:

[jira] [Updated] (KAFKA-6739) Broker receives error when handling request with java.lang.IllegalArgumentException: Magic v0 does not support record headers

2018-04-02 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6739: --- Priority: Critical (was: Major) > Broker receives error when handling request with >

[jira] [Commented] (KAFKA-5337) Partition assignment strategy that distributes lag evenly across consumers in each group

2018-04-02 Thread Matt Garbis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423047#comment-16423047 ] Matt Garbis commented on KAFKA-5337: Is this dead? This would be a great new feature to have out of

[jira] [Commented] (KAFKA-6500) Can not build aggregatedJavadoc

2018-04-02 Thread Pavel Timofeev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422985#comment-16422985 ] Pavel Timofeev commented on KAFKA-6500: --- Well, I'm doing this under FreeBSD. kafka 1.1.0, openjdk

[jira] [Updated] (KAFKA-6739) Broker receives error when handling request with java.lang.IllegalArgumentException: Magic v0 does not support record headers

2018-04-02 Thread Koelli Mungee (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Koelli Mungee updated KAFKA-6739: - Description: A broker running at 1.0.0 with the following properties    {code:java}

[jira] [Assigned] (KAFKA-6739) Broker receives error when handling request with java.lang.IllegalArgumentException: Magic v0 does not support record headers

2018-04-02 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah reassigned KAFKA-6739: --- Assignee: Dhruvil Shah > Broker receives error when handling request with >

[jira] [Created] (KAFKA-6739) Broker receives error when handling request with java.lang.IllegalArgumentException: Magic v0 does not support record headers

2018-04-02 Thread Koelli Mungee (JIRA)
Koelli Mungee created KAFKA-6739: Summary: Broker receives error when handling request with java.lang.IllegalArgumentException: Magic v0 does not support record headers Key: KAFKA-6739 URL:

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

2018-04-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422821#comment-16422821 ] Ted Yu commented on KAFKA-6681: --- 0.10.2.1 was quite old. It would be nice if you can reproduce this

[jira] [Assigned] (KAFKA-6731) waitOnState waits for the wrong state instead of the target one

2018-04-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6731: -- Assignee: huxihx (was: Matthias J. Sax) > waitOnState waits for the wrong state

[jira] [Assigned] (KAFKA-6731) waitOnState waits for the wrong state instead of the target one

2018-04-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6731: -- Assignee: Matthias J. Sax (was: huxihx) > waitOnState waits for the wrong state

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

2018-04-02 Thread Narayan Periwal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422654#comment-16422654 ] Narayan Periwal commented on KAFKA-6681: [~yuzhih...@gmail.com], Thanks for looking into this

[jira] [Commented] (KAFKA-5674) max.connections.per.ip minimum value to be zero to allow IP address blocking

2018-04-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422643#comment-16422643 ] ASF GitHub Bot commented on KAFKA-5674: --- hachikuji closed pull request #3610: KAFKA-5674:

[jira] [Commented] (KAFKA-6738) Kafka Connect handling of bad data

2018-04-02 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422607#comment-16422607 ] Randall Hauch commented on KAFKA-6738: -- See also [this dev list

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

2018-04-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422594#comment-16422594 ] Ted Yu commented on KAFKA-6681: --- I am digging into RangeAssignor. Meanwhile, please try out

[jira] [Created] (KAFKA-6738) Kafka Connect handling of bad data

2018-04-02 Thread Randall Hauch (JIRA)
Randall Hauch created KAFKA-6738: Summary: Kafka Connect handling of bad data Key: KAFKA-6738 URL: https://issues.apache.org/jira/browse/KAFKA-6738 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6729) KTable should use user source topics if possible and not create changelog topic

2018-04-02 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422576#comment-16422576 ] John Roesler commented on KAFKA-6729: - Maybe worth clarifying, this is a performance regression, not a

[jira] [Updated] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-02 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6728: - Priority: Critical (was: Major) > Kafka Connect Header Null Pointer Exception >

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

2018-04-02 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422538#comment-16422538 ] John Roesler commented on KAFKA-6535: - Oh, if you're not subscribed to the dev mailing list, you

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

2018-04-02 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422537#comment-16422537 ] John Roesler commented on KAFKA-6535: - Hey [~Khairy], There's not much to it; the instructions here

[jira] [Comment Edited] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

2018-04-02 Thread Narayan Periwal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422150#comment-16422150 ] Narayan Periwal edited comment on KAFKA-6681 at 4/2/18 11:23 AM: -

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

2018-04-02 Thread Narayan Periwal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422150#comment-16422150 ] Narayan Periwal commented on KAFKA-6681: [~yuzhih...@gmail.com] I assume you are asking about this

[jira] [Resolved] (KAFKA-6645) Host Affinity to facilitate faster restarts of kafka streams applications

2018-04-02 Thread Giridhar Addepalli (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Giridhar Addepalli resolved KAFKA-6645. --- Resolution: Information Provided > Host Affinity to facilitate faster restarts of

[jira] [Commented] (KAFKA-6645) Host Affinity to facilitate faster restarts of kafka streams applications

2018-04-02 Thread Giridhar Addepalli (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422107#comment-16422107 ] Giridhar Addepalli commented on KAFKA-6645: --- [~guozhang]  & [~mjsax] Thank you for comments.

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

2018-04-02 Thread Khaireddine Rezgui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16421981#comment-16421981 ] Khaireddine Rezgui commented on KAFKA-6535: --- Hi guys, can someone help me to create the KIP,