[jira] [Assigned] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext

2018-03-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6725: Assignee: Matt Farmer > Indicate "isClosing" in the SinkTaskContext >

[jira] [Reopened] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates

2018-03-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-6390: > Update ZooKeeper to 3.4.11, Gradle and other minor updates >

[jira] [Updated] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates

2018-03-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6390: --- Fix Version/s: 1.2.0 > Update ZooKeeper to 3.4.11, Gradle and other minor updates >

[jira] [Updated] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates

2018-03-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6390: --- Fix Version/s: (was: 1.1.0) > Update ZooKeeper to 3.4.11, Gradle and other minor updates >

[jira] [Commented] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates

2018-03-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16421059#comment-16421059 ] Ismael Juma commented on KAFKA-6390: The ZooKeeper 3.4.11 change was reverted via 825bfe5 due to

[jira] [Created] (KAFKA-6730) Simplify state store recovery

2018-03-30 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6730: -- Summary: Simplify state store recovery Key: KAFKA-6730 URL: https://issues.apache.org/jira/browse/KAFKA-6730 Project: Kafka Issue Type: Improvement

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

2018-03-30 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6729: -- Summary: KTable should use user source topics if possible and not create changelog topic Key: KAFKA-6729 URL: https://issues.apache.org/jira/browse/KAFKA-6729

[jira] [Commented] (KAFKA-6704) Checking hasNext from SegementIterator could throw InvalidStateStoreException

2018-03-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420996#comment-16420996 ] ASF GitHub Bot commented on KAFKA-6704: --- bbejeck opened a new pull request #4801: KAFKA-6704:

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

2018-03-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420783#comment-16420783 ] ASF GitHub Bot commented on KAFKA-6728: --- tedyu opened a new pull request #4800: KAFKA-6728 Kafka

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

2018-03-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420634#comment-16420634 ] Ted Yu edited comment on KAFKA-6728 at 3/30/18 5:54 PM: Here is the related line

[jira] [Assigned] (KAFKA-6538) Enhance ByteStore exceptions with more context information

2018-03-30 Thread Jagadesh Adireddi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-6538: Assignee: Jagadesh Adireddi > Enhance ByteStore exceptions with more context

[jira] [Commented] (KAFKA-6538) Enhance ByteStore exceptions with more context information

2018-03-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420672#comment-16420672 ] Matthias J. Sax commented on KAFKA-6538: That is correct, and that is exactly the issue. In older

[jira] [Commented] (KAFKA-6538) Enhance ByteStore exceptions with more context information

2018-03-30 Thread Jagadesh Adireddi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420657#comment-16420657 ] Jagadesh Adireddi commented on KAFKA-6538: -- Hi [~mjsax], To work on this ticket, I would like to 

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

2018-03-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420634#comment-16420634 ] Ted Yu commented on KAFKA-6728: --- Here is the related line where NPE was thrown: {code}

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

2018-03-30 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420619#comment-16420619 ] Randall Hauch commented on KAFKA-6417: -- [~ChrisEgerton], the output concept mentioned in KAFKA-6675

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

2018-03-30 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420589#comment-16420589 ] John Roesler commented on KAFKA-6474: - Yeah, I agree. Just prefix it as WIP, and no one will judge ;)

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

2018-03-30 Thread Philippe Hong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philippe Hong updated KAFKA-6728: - Description: I am trying to use the newly released Kafka Connect that supports headers by using

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

2018-03-30 Thread Philippe Hong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philippe Hong updated KAFKA-6728: - Description: I am trying to use the newly released Kafka Connect that supports headers by using

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

2018-03-30 Thread Philippe Hong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philippe Hong updated KAFKA-6728: - Description: I am trying to use the newly released Kafka Connect that supports headers by using

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

2018-03-30 Thread Philippe Hong (JIRA)
Philippe Hong created KAFKA-6728: Summary: Kafka Connect Header Null Pointer Exception Key: KAFKA-6728 URL: https://issues.apache.org/jira/browse/KAFKA-6728 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6642) Rack aware task assignment in kafka streams

2018-03-30 Thread Ashish Surana (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420345#comment-16420345 ] Ashish Surana commented on KAFKA-6642: -- Hi Wang, Sure, I am working with Deepak on this. PR is very

[jira] [Comment Edited] (KAFKA-6642) Rack aware task assignment in kafka streams

2018-03-30 Thread Ashish Surana (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416778#comment-16416778 ] Ashish Surana edited comment on KAFKA-6642 at 3/30/18 10:05 AM: Current

[jira] [Commented] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

2018-03-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420252#comment-16420252 ] ASF GitHub Bot commented on KAFKA-6592: --- huxihx opened a new pull request #4797: KAFKA-6592: