[jira] [Comment Edited] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190802#comment-17190802 ] Peter Davis edited comment on KAFKA-10134 at 9/4/20, 4:07 PM: -- I'd like to

[jira] [Commented] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190802#comment-17190802 ] Peter Davis commented on KAFKA-10134: - I'd like to see the title of this bug clarified: It is worse

[jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152978#comment-17152978 ] Peter Davis commented on KAFKA-8770: Could I request this Jira be split (or new one being created) to

[jira] [Commented] (KAFKA-5983) Cannot mirror Avro-encoded data using the Apache Kafka MirrorMaker

[ https://issues.apache.org/jira/browse/KAFKA-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793144#comment-16793144 ] Peter Davis commented on KAFKA-5983: Thank you very much for the link to your transfer tool,

[jira] [Commented] (KAFKA-5983) Cannot mirror Avro-encoded data using the Apache Kafka MirrorMaker

[ https://issues.apache.org/jira/browse/KAFKA-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793062#comment-16793062 ] Peter Davis commented on KAFKA-5983: [~cricket007] said: {quote}the only reason I see have two

[jira] [Comment Edited] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769912#comment-16769912 ] Peter Davis edited comment on KAFKA-7088 at 2/16/19 12:58 AM: -- Encountered

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769912#comment-16769912 ] Peter Davis commented on KAFKA-7088: Encountered this bug today with 0.11.0 client.  Similar same

[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=16369654#comment-16369654 ] Peter Davis commented on KAFKA-5285: Noting that after upgrading from 0.11.0.1 to 1.0.1 today, I'm

[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=16367673#comment-16367673 ] Peter Davis commented on KAFKA-5285: Thank you Guozhang for looking into this. Good point Xavier; for

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323184#comment-16323184 ] Peter Davis commented on KAFKA-4850: Request: RocksDB memory usage (off Java heap) is already hard to

[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=16291962#comment-16291962 ] Peter Davis edited comment on KAFKA-5285 at 12/15/17 3:08 AM: -- In debugging a

[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=16291962#comment-16291962 ] Peter Davis commented on KAFKA-5285: In debugging a recent performance blocker in an app of mine, I'm

[jira] [Commented] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183129#comment-16183129 ] Peter Davis commented on KAFKA-5970: In our case, turns out there's a very chatty consumer calling

[jira] [Commented] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179293#comment-16179293 ] Peter Davis commented on KAFKA-5970: Thanks [~rsivaram] and [~hachikuji] for looking at this. Even a

[jira] [Commented] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179184#comment-16179184 ] Peter Davis commented on KAFKA-5970: [~rsivaram] Thanks for looking into this so quickly. We agree,

[jira] [Commented] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179159#comment-16179159 ] Peter Davis commented on KAFKA-5970: I ended up here because of commonality of deadlock in

[jira] [Updated] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Davis updated KAFKA-5970: --- Attachment: jstack.txt [~ijuma] No, not using transactions. Attached stack dump. (Also have a heap

[jira] [Commented] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179141#comment-16179141 ] Peter Davis commented on KAFKA-5970: It looks like we are seeing this repeatedly in a production

[jira] [Comment Edited] (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=16145648#comment-16145648 ] Peter Davis edited comment on KAFKA-2729 at 8/29/17 5:27 PM: - [~junrao] Per

[jira] [Commented] (KAFKA-4674) Frequent ISR shrinking and expanding and disconnects among brokers

[ https://issues.apache.org/jira/browse/KAFKA-4674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16145731#comment-16145731 ] Peter Davis commented on KAFKA-4674: Duplicate of KAFKA-2729? > Frequent ISR shrinking and expanding

[jira] [Comment Edited] (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=16145648#comment-16145648 ] Peter Davis edited comment on KAFKA-2729 at 8/29/17 4:48 PM: - [~junrao] Per

[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=16145648#comment-16145648 ] Peter Davis commented on KAFKA-2729: [~junrao] Per your previous