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

[ https://issues.apache.org/jira/browse/KAFKA-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366753#comment-16366753 ] Rajini Sivaram commented on KAFKA-6565: --- [~berman] Looks like this could be due to t

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

[ https://issues.apache.org/jira/browse/KAFKA-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366753#comment-16366753 ] Rajini Sivaram edited comment on KAFKA-6565 at 2/16/18 9:12 AM:

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

[ 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] [Commented] (KAFKA-4277) creating ephemeral node already exist

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367059#comment-16367059 ] Pankaj commented on KAFKA-6156: --- Anybody, Is the bug fixed released with kafka_2.11-1.0.0 ?.

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

[ https://issues.apache.org/jira/browse/KAFKA-6156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367324#comment-16367324 ] Rajini Sivaram commented on KAFKA-6156: --- [~pmishra01] It will be fixed in 1.1, expec

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367553#comment-16367553 ] Xavier Léauté edited comment on KAFKA-5285 at 2/16/18 4:37 PM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367553#comment-16367553 ] Xavier Léauté edited comment on KAFKA-5285 at 2/16/18 4:49 PM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367553#comment-16367553 ] Xavier Léauté edited comment on KAFKA-5285 at 2/16/18 5:08 PM: -

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

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 Issu

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

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367673#comment-16367673 ] Peter Davis commented on KAFKA-5285: Thank you Guozhang for looking into this. Good p

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367822#comment-16367822 ] Ashish Surana commented on KAFKA-6555: -- First let's see when a task can go to restora

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367822#comment-16367822 ] Ashish Surana edited comment on KAFKA-6555 at 2/16/18 8:10 PM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367822#comment-16367822 ] Ashish Surana edited comment on KAFKA-6555 at 2/16/18 8:10 PM: -

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

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

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

[ 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-6569) Reflection in OffsetIndex and TimeIndex construction

[ https://issues.apache.org/jira/browse/KAFKA-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367873#comment-16367873 ] Ismael Juma commented on KAFKA-6569: Yes, we should definitely do this. Personally, I

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367875#comment-16367875 ] Matthias J. Sax commented on KAFKA-6555: That makes sense to me. We need to figure

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

[ https://issues.apache.org/jira/browse/KAFKA-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367877#comment-16367877 ] Ismael Juma commented on KAFKA-6569: If you submit a PR today, we can include it in 1.

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

[ https://issues.apache.org/jira/browse/KAFKA-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367880#comment-16367880 ] Jason Gustafson commented on KAFKA-6238: [~bobrik] Thanks for reporting. It looks

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

[ https://issues.apache.org/jira/browse/KAFKA-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367886#comment-16367886 ] Ivan Babrou commented on KAFKA-6238: Thanks, that's precisely what we've done. > Issu

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

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367892#comment-16367892 ] Xavier Léauté commented on KAFKA-5285: -- [~davispw] yes I understand your concern, and

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

[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367896#comment-16367896 ] ASF GitHub Bot commented on KAFKA-6536: --- mjsax closed pull request #4569: KAFKA-6536

[jira] [Resolved] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4186. Resolution: Fixed We did some test rework and this did not fail for a while. Closing this ti

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

[ https://issues.apache.org/jira/browse/KAFKA-6430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16367993#comment-16367993 ] ASF GitHub Bot commented on KAFKA-6430: --- ijuma closed pull request #4537: KAFKA-6430

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

[ 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

[ 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

[ 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 > -

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

[ 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 > FetchRequestTest.testDownConversionWithConnecti

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

[ https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16368075#comment-16368075 ] ASF GitHub Bot commented on KAFKA-6568: --- hachikuji closed pull request #4580: KAFKA-

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

[ 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 > LogCleanerManage

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

[ 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 wh