[jira] [Commented] (KAFKA-8172) FileSystemException: The process cannot access the file because it is being used by another process

[ https://issues.apache.org/jira/browse/KAFKA-8172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827447#comment-16827447 ] Dongjoon Hyun commented on KAFKA-8172: -- Can we remove `2.2.0` from the `Fix version` because 2.2.0

[jira] [Assigned] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Lopez reassigned KAFKA-8199: - Assignee: Jose Lopez > ClassCastException when trying to groupBy after suppress >

[jira] [Assigned] (KAFKA-8270) Kafka retention hour is not working

[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu reassigned KAFKA-8270: - Assignee: (was: Richard Yu) > Kafka retention hour is not working >

[jira] [Commented] (KAFKA-8270) Kafka retention hour is not working

[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827381#comment-16827381 ] Richard Yu commented on KAFKA-8270: --- Oh [~tony2011] sorry didnt even know the ticket was assigned to

[jira] [Commented] (KAFKA-8299) Add type-safe instantiation of generic classes to AbstractConfig

[ https://issues.apache.org/jira/browse/KAFKA-8299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827367#comment-16827367 ] ASF GitHub Bot commented on KAFKA-8299: --- C0urante commented on pull request #6644: KAFKA-8299: Add

[jira] [Created] (KAFKA-8300) kafka broker did not recovery from quota limit after quota setting is removed

Yu Yang created KAFKA-8300: -- Summary: kafka broker did not recovery from quota limit after quota setting is removed Key: KAFKA-8300 URL: https://issues.apache.org/jira/browse/KAFKA-8300 Project: Kafka

[jira] [Updated] (KAFKA-8300) kafka broker did not recover from quota limit after quota setting is removed

[ https://issues.apache.org/jira/browse/KAFKA-8300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated KAFKA-8300: --- Summary: kafka broker did not recover from quota limit after quota setting is removed (was: kafka broker

[jira] [Created] (KAFKA-8299) Add type-safe instantiation of generic classes to AbstractConfig

Chris Egerton created KAFKA-8299: Summary: Add type-safe instantiation of generic classes to AbstractConfig Key: KAFKA-8299 URL: https://issues.apache.org/jira/browse/KAFKA-8299 Project: Kafka

[jira] [Updated] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

[ https://issues.apache.org/jira/browse/KAFKA-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8254: - Fix Version/s: 2.1.2 > Suppress incorrectly passes a null topic to the serdes >

[jira] [Commented] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

[ https://issues.apache.org/jira/browse/KAFKA-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827345#comment-16827345 ] ASF GitHub Bot commented on KAFKA-8254: --- guozhangwang commented on pull request #6641: KAFKA-8254:

[jira] [Updated] (KAFKA-8298) ConcurrentModificationException Possible when optimizing for repartition nodes

[ https://issues.apache.org/jira/browse/KAFKA-8298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8298: - Description: As indicated in the title. When processing multiple key-changing operations during

[jira] [Commented] (KAFKA-8298) ConcurrentModificationException Possible when optimizing for repartition nodes

[ https://issues.apache.org/jira/browse/KAFKA-8298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827322#comment-16827322 ] ASF GitHub Bot commented on KAFKA-8298: --- bbejeck commented on pull request #6643: KAFKA-8298: Fix

[jira] [Created] (KAFKA-8298) ConcurrentModificationException Possible when optimizing for repartition nodes

Bill Bejeck created KAFKA-8298: -- Summary: ConcurrentModificationException Possible when optimizing for repartition nodes Key: KAFKA-8298 URL: https://issues.apache.org/jira/browse/KAFKA-8298 Project:

[jira] [Resolved] (KAFKA-8029) Add in-memory bytes-only session store implementation

[ https://issues.apache.org/jira/browse/KAFKA-8029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8029. -- Resolution: Fixed Fix Version/s: 2.3.0 > Add in-memory bytes-only session store

[jira] [Commented] (KAFKA-8029) Add in-memory bytes-only session store implementation

[ https://issues.apache.org/jira/browse/KAFKA-8029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827295#comment-16827295 ] ASF GitHub Bot commented on KAFKA-8029: --- guozhangwang commented on pull request #6525: KAFKA-8029:

[jira] [Resolved] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change

[ https://issues.apache.org/jira/browse/KAFKA-7862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-7862. Resolution: Fixed > Modify JoinGroup logic to incorporate group.instance.id change >

[jira] [Created] (KAFKA-8297) Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics

Michael Drogalis created KAFKA-8297: --- Summary: Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics Key: KAFKA-8297 URL: https://issues.apache.org/jira/browse/KAFKA-8297

[jira] [Created] (KAFKA-8296) Kafka Streams branch method raises type warnings

Michael Drogalis created KAFKA-8296: --- Summary: Kafka Streams branch method raises type warnings Key: KAFKA-8296 URL: https://issues.apache.org/jira/browse/KAFKA-8296 Project: Kafka Issue

[jira] [Created] (KAFKA-8295) Optimize count() using RocksDB merge operator

Sophie Blee-Goldman created KAFKA-8295: -- Summary: Optimize count() using RocksDB merge operator Key: KAFKA-8295 URL: https://issues.apache.org/jira/browse/KAFKA-8295 Project: Kafka

[jira] [Commented] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change

[ https://issues.apache.org/jira/browse/KAFKA-7862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827209#comment-16827209 ] ASF GitHub Bot commented on KAFKA-7862: --- guozhangwang commented on pull request #6177: KAFKA-7862 &

[jira] [Commented] (KAFKA-8294) Batch StopReplica requests with partition deletion and add test cases

[ https://issues.apache.org/jira/browse/KAFKA-8294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827164#comment-16827164 ] ASF GitHub Bot commented on KAFKA-8294: --- hachikuji commented on pull request #6642: KAFKA-8294;

[jira] [Created] (KAFKA-8294) Batch StopReplica requests with partition deletion and add test cases

Jason Gustafson created KAFKA-8294: -- Summary: Batch StopReplica requests with partition deletion and add test cases Key: KAFKA-8294 URL: https://issues.apache.org/jira/browse/KAFKA-8294 Project:

[jira] [Commented] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf

[ https://issues.apache.org/jira/browse/KAFKA-7631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827153#comment-16827153 ] koert kuipers commented on KAFKA-7631: -- i fixed this by adding both Krb5LoginModule and

[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827123#comment-16827123 ] Ted Yu edited comment on KAFKA-5998 at 4/26/19 5:31 PM:

[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827123#comment-16827123 ] Ted Yu edited comment on KAFKA-5998 at 4/26/19 5:12 PM:

[jira] [Commented] (KAFKA-7847) KIP-421: Automatically resolve external configurations.

[ https://issues.apache.org/jira/browse/KAFKA-7847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827128#comment-16827128 ] TEJAL ADSUL commented on KAFKA-7847: [~rhauch] [~cmccabe], [~rsivaram] Please could you'll review the

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827123#comment-16827123 ] Ted Yu commented on KAFKA-5998: --- https://pastebin.com/Y247UZgb shows what I mentioned earlier. In

[jira] [Commented] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

[ https://issues.apache.org/jira/browse/KAFKA-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827118#comment-16827118 ] ASF GitHub Bot commented on KAFKA-8254: --- vvcephei commented on pull request #6641: KAFKA-8254: Pass

[jira] [Resolved] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

[ https://issues.apache.org/jira/browse/KAFKA-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8254. -- Resolution: Fixed Fix Version/s: (was: 2.1.2) Resolved for trunk / 2.2 now, will

[jira] [Commented] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

[ https://issues.apache.org/jira/browse/KAFKA-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827106#comment-16827106 ] ASF GitHub Bot commented on KAFKA-8254: --- guozhangwang commented on pull request #6602: KAFKA-8254:

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827089#comment-16827089 ] Ted Yu commented on KAFKA-5998: --- [~mparthas]: >From your comment on Apr 8th, it seems that making the value

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827025#comment-16827025 ] Jingguo Yao commented on KAFKA-5998: We are using Confluent 5.1.0 which is based on kafka_2.11-2.1.1.

[jira] [Created] (KAFKA-8293) Messages undelivered when small quotas applied

Kirill Kulikov created KAFKA-8293: - Summary: Messages undelivered when small quotas applied Key: KAFKA-8293 URL: https://issues.apache.org/jira/browse/KAFKA-8293 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf

[ https://issues.apache.org/jira/browse/KAFKA-7631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827023#comment-16827023 ] koert kuipers commented on KAFKA-7631: -- it is not clear to me how i should handle this situation.

[jira] [Comment Edited] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826951#comment-16826951 ] JMVM edited comment on KAFKA-8282 at 4/26/19 2:23 PM: -- Hi [~wushujames] We already

[jira] [Comment Edited] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826951#comment-16826951 ] JMVM edited comment on KAFKA-8282 at 4/26/19 2:24 PM: -- Hi [~wushujames] We already

[jira] [Comment Edited] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826951#comment-16826951 ] JMVM edited comment on KAFKA-8282 at 4/26/19 2:24 PM: -- Hi [~wushujames] We already

[jira] [Commented] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826951#comment-16826951 ] JMVM commented on KAFKA-8282: - Hi [~wushujames] We already broker quota configuration in place: {code:java}

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826946#comment-16826946 ] Shawn YUAN commented on KAFKA-2729: --- Thank you [~DEvil], I'm searching for if any git commits diff

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826796#comment-16826796 ] Matthias J. Sax commented on KAFKA-8289: [~vvcephei] Assigning this to you for visibility. >

[jira] [Updated] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8289: --- Priority: Major (was: Blocker) > KTable, Long> can't be suppressed >

[jira] [Assigned] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8289: -- Assignee: John Roesler > KTable, Long> can't be suppressed >

[jira] [Commented] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

[ https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826720#comment-16826720 ] ASF GitHub Bot commented on KAFKA-8200: --- pkleindl commented on pull request #6556: KAFKA-8200:

[jira] [Closed] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

[ https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl closed KAFKA-8200. - > TopologyTestDriver should offer an iterable signature of readOutput >

[jira] [Resolved] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

[ https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl resolved KAFKA-8200. --- Resolution: Won't Do Discarded in favor of 

[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826694#comment-16826694 ] Liu commented on KAFKA-7697: [~little brother ma]  wo also hit the same issue with 2.1.1 .I checked the

[jira] [Commented] (KAFKA-7870) Error sending fetch request (sessionId=1578860481, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read.

[ https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826664#comment-16826664 ] Liu commented on KAFKA-7870: We actually found this in version 2.1.1 as well > Error sending fetch request