[jira] [Resolved] (KAFKA-6537) Duplicate consumers after consumer group rebalance

2018-02-16 Thread Michael Golovanov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Golovanov resolved KAFKA-6537. -- Resolution: Duplicate > Duplicate consumers after consumer group rebalance >

[jira] [Comment Edited] (KAFKA-6565) Sudden unresponsiveness from broker + file descriptor leak

2018-02-16 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366753#comment-16366753 ] Rajini Sivaram edited comment on KAFKA-6565 at 2/16/18 9:12 AM: [~berman]

[jira] [Commented] (KAFKA-6565) Sudden unresponsiveness from broker + file descriptor leak

2018-02-16 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366753#comment-16366753 ] Rajini Sivaram commented on KAFKA-6565: --- [~berman] Looks like this could be due to the deadlocks

[jira] [Commented] (KAFKA-6568) LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

2018-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368075#comment-16368075 ] ASF GitHub Bot commented on KAFKA-6568: --- hachikuji closed pull request #4580: KAFKA-6568; The log

[jira] [Resolved] (KAFKA-6228) Intermittent test failure in FetchRequestTest.testDownConversionWithConnectionFailure

2018-02-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6228. --- Resolution: Cannot Reproduce > Intermittent test failure in >

[jira] [Resolved] (KAFKA-6568) LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

2018-02-16 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6568. Resolution: Fixed Fix Version/s: 1.0.2 0.11.0.3 >

[jira] [Reopened] (KAFKA-6238) Issues with protocol version when applying a rolling upgrade to 1.0.0

2018-02-16 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-6238: Reopening this since there is a bug in the config validation. > Issues with protocol version

[jira] [Commented] (KAFKA-4277) creating ephemeral node already exist

2018-02-16 Thread Birger Brunswiek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366818#comment-16366818 ] Birger Brunswiek commented on KAFKA-4277: - {quote} Nico Meyer, do you know if the conflicting

[jira] [Commented] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

2018-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367553#comment-16367553 ] Xavier Léauté commented on KAFKA-5285: -- {quote}# For lower range, we just use the {{keyFrom bytes}},

[jira] [Comment Edited] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

2018-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367553#comment-16367553 ] Xavier Léauté edited comment on KAFKA-5285 at 2/16/18 4:49 PM: --- {quote}# For

[jira] [Comment Edited] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

2018-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367553#comment-16367553 ] Xavier Léauté edited comment on KAFKA-5285 at 2/16/18 4:37 PM: --- {quote}# For

[jira] [Commented] (KAFKA-6156) JmxReporter can't handle windows style directory paths

2018-02-16 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367324#comment-16367324 ] Rajini Sivaram commented on KAFKA-6156: --- [~pmishra01] It will be fixed in 1.1, expected to be

[jira] [Commented] (KAFKA-6156) JmxReporter can't handle windows style directory paths

2018-02-16 Thread Pankaj (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367059#comment-16367059 ] Pankaj commented on KAFKA-6156: --- Anybody, Is the bug fixed released with kafka_2.11-1.0.0 ?. I'm facing

[jira] [Comment Edited] (KAFKA-6555) Making state store queryable during restoration

2018-02-16 Thread Ashish Surana (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367822#comment-16367822 ] Ashish Surana edited comment on KAFKA-6555 at 2/16/18 8:10 PM: --- First let's

[jira] [Comment Edited] (KAFKA-6555) Making state store queryable during restoration

2018-02-16 Thread Ashish Surana (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367822#comment-16367822 ] Ashish Surana edited comment on KAFKA-6555 at 2/16/18 8:10 PM: --- First let's

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

2018-02-16 Thread Ashish Surana (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367822#comment-16367822 ] Ashish Surana commented on KAFKA-6555: -- First let's see when a task can go to restoration state: *

[jira] [Comment Edited] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

2018-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367553#comment-16367553 ] Xavier Léauté edited comment on KAFKA-5285 at 2/16/18 5:08 PM: --- {quote}# For

[jira] [Created] (KAFKA-6569) Reflection in OffsetIndex and TimeIndex construction

2018-02-16 Thread Kyle Ambroff-Kao (JIRA)
Kyle Ambroff-Kao created KAFKA-6569: --- Summary: Reflection in OffsetIndex and TimeIndex construction Key: KAFKA-6569 URL: https://issues.apache.org/jira/browse/KAFKA-6569 Project: Kafka

[jira] [Commented] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

2018-02-16 Thread Peter Davis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367673#comment-16367673 ] Peter Davis commented on KAFKA-5285: Thank you Guozhang for looking into this. Good point Xavier; for

[jira] [Commented] (KAFKA-6306) Auto-commit of offsets fail, and not recover forever...

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

[jira] [Commented] (KAFKA-6536) Streams quickstart pom.xml is missing versions for a bunch of plugins

2018-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367896#comment-16367896 ] ASF GitHub Bot commented on KAFKA-6536: --- mjsax closed pull request #4569: KAFKA-6536: Adding

[jira] [Resolved] (KAFKA-5430) new consumers getting data for revoked partitions

2018-02-16 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5430. Resolution: Fixed I think this issue was fixed in KAFKA-5154. Please reopen if you think it

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

2018-02-16 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367875#comment-16367875 ] Matthias J. Sax commented on KAFKA-6555: That makes sense to me. We need to figure out a way, to

[jira] [Commented] (KAFKA-6569) Reflection in OffsetIndex and TimeIndex construction

2018-02-16 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367873#comment-16367873 ] Ismael Juma commented on KAFKA-6569: Yes, we should definitely do this. Personally, I think the

[jira] [Commented] (KAFKA-6424) QueryableStateIntegrationTest#queryOnRebalance should accept raw text

2018-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367849#comment-16367849 ] ASF GitHub Bot commented on KAFKA-6424: --- mjsax closed pull request #4549: KAFKA-6424:

[jira] [Commented] (KAFKA-6238) Issues with protocol version when applying a rolling upgrade to 1.0.0

2018-02-16 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367880#comment-16367880 ] Jason Gustafson commented on KAFKA-6238: [~bobrik] Thanks for reporting. It looks like there is a

[jira] [Commented] (KAFKA-6238) Issues with protocol version when applying a rolling upgrade to 1.0.0

2018-02-16 Thread Ivan Babrou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367886#comment-16367886 ] Ivan Babrou commented on KAFKA-6238: Thanks, that's precisely what we've done. > Issues with protocol

[jira] [Commented] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

2018-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367892#comment-16367892 ] Xavier Léauté commented on KAFKA-5285: -- [~davispw] yes I understand your concern, and that's part the

[jira] [Commented] (KAFKA-6430) Improve Kafka GZip compression performance

2018-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367993#comment-16367993 ] ASF GitHub Bot commented on KAFKA-6430: --- ijuma closed pull request #4537: KAFKA-6430: Add buffer

[jira] [Assigned] (KAFKA-6430) Improve Kafka GZip compression performance

2018-02-16 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-6430: -- Assignee: Ying Zheng > Improve Kafka GZip compression performance >

[jira] [Resolved] (KAFKA-6430) Improve Kafka GZip compression performance

2018-02-16 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6430. Resolution: Fixed Fix Version/s: 1.1.0 > Improve Kafka GZip compression performance >

[jira] [Updated] (KAFKA-6430) Improve Kafka GZip compression performance

2018-02-16 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6430: --- Priority: Major (was: Minor) > Improve Kafka GZip compression performance >