[jira] [Resolved] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

2018-03-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6486. Resolution: Fixed > TimeWindows causes unordered calls to windowed aggregation functions >

[jira] [Assigned] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

2018-03-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6486: -- Assignee: Asutosh Pandya > TimeWindows causes unordered calls to windowed aggregation

[jira] [Commented] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404345#comment-16404345 ] ASF GitHub Bot commented on KAFKA-6486: --- mjsax closed pull request #4628: KAFKA-6486: Implemented

[jira] [Updated] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

2018-03-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6486: --- Fix Version/s: 1.2.0 > TimeWindows causes unordered calls to windowed aggregation functions >

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

2018-03-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404326#comment-16404326 ] Matthias J. Sax commented on KAFKA-6520: This issue is target to Kafka's Streams API, ie, if one

[jira] [Commented] (KAFKA-6659) Improve error message if state store is not found

2018-03-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404323#comment-16404323 ] Matthias J. Sax commented on KAFKA-6659: Thanks for picking this up. I think it would be helpful

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2018-03-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 3/19/18 1:28 AM: Patch looks good to me .

[jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name

2018-03-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 3/19/18 1:27 AM: Thanks for taking it .

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

2018-03-18 Thread Milind Jain (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404180#comment-16404180 ] Milind Jain commented on KAFKA-6520: Hi [~mjsax] [~mwkohout] I tried reproducing the issue On using

[jira] [Updated] (KAFKA-6679) Random corruption (CRC validation issues)

2018-03-18 Thread Ari Uka (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ari Uka updated KAFKA-6679: --- Description: I'm running into a really strange issue on production. I have 3 brokers and randomly consumers

[jira] [Updated] (KAFKA-6679) Random corruption (CRC validation issues)

2018-03-18 Thread Ari Uka (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ari Uka updated KAFKA-6679: --- Description: I'm running into a really strange issue on production. I have 3 brokers and randomly consumers

[jira] [Updated] (KAFKA-6679) Random corruption (CRC validation issues)

2018-03-18 Thread Ari Uka (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ari Uka updated KAFKA-6679: --- Description: I'm running into a really strange issue on production. I have 3 brokers and randomly consumers

[jira] [Updated] (KAFKA-6679) Random corruption (CRC validation issues)

2018-03-18 Thread Ari Uka (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ari Uka updated KAFKA-6679: --- Description: I'm running into a really strange issue on production. I have 3 brokers and randomly consumers

[jira] [Updated] (KAFKA-6679) Random corruption (CRC validation issues)

2018-03-18 Thread Ari Uka (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ari Uka updated KAFKA-6679: --- Description: I'm running into a really strange issue on production. I have 3 brokers and randomly consumers

[jira] [Updated] (KAFKA-6679) Random corruption (CRC validation issues)

2018-03-18 Thread Ari Uka (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ari Uka updated KAFKA-6679: --- Description: I'm running into a really strange issue on production. I have 3 brokers and randomly consumers

[jira] [Created] (KAFKA-6679) Random corruption (CRC validation issues)

2018-03-18 Thread Ari Uka (JIRA)
Ari Uka created KAFKA-6679: -- Summary: Random corruption (CRC validation issues) Key: KAFKA-6679 URL: https://issues.apache.org/jira/browse/KAFKA-6679 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-6678) Upgrade dependencies with later release versions

2018-03-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6678: -- Attachment: k-update.txt > Upgrade dependencies with later release versions >

[jira] [Created] (KAFKA-6678) Upgrade dependencies with later release versions

2018-03-18 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6678: - Summary: Upgrade dependencies with later release versions Key: KAFKA-6678 URL: https://issues.apache.org/jira/browse/KAFKA-6678 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6659) Improve error message if state store is not found

2018-03-18 Thread Stuart (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403894#comment-16403894 ] Stuart commented on KAFKA-6659: --- Hi I would like to pick this Jira up. I have found the code section