[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&focusedCommentId=17190802#comment-17190802 ] Peter Davis edited comment on KAFKA-10134 at 9/4/20, 4:07 PM:

[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&focusedCommentId=17190802#comment-17190802 ] Peter Davis commented on KAFKA-10134: - I'd like to see the title of this bug clarifi

[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&focusedCommentId=17152978#comment-17152978 ] Peter Davis commented on KAFKA-8770: Could I request this Jira be split (or new one b

[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&focusedCommentId=16793144#comment-16793144 ] Peter Davis commented on KAFKA-5983: Thank you very much for the link to your transfe

[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&focusedCommentId=16793062#comment-16793062 ] Peter Davis commented on KAFKA-5983: [~cricket007] said: {quote}the only reason I see

[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&focusedCommentId=16769912#comment-16769912 ] Peter Davis edited comment on KAFKA-7088 at 2/16/19 12:58 AM: -

[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&focusedCommentId=16769912#comment-16769912 ] Peter Davis commented on KAFKA-7088: Encountered this bug today with 0.11.0 client. 

[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=16369654#comment-16369654 ] Peter Davis commented on KAFKA-5285: Noting that after upgrading from 0.11.0.1 to 1.0.

[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-4850) RocksDb cannot use Bloom Filters

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

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

[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=16291962#comment-16291962 ] Peter Davis commented on KAFKA-5285: In debugging a recent performance blocker in an 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&focusedCommentId=16183129#comment-16183129 ] Peter Davis commented on KAFKA-5970: In our case, turns out there's a very chatty cons

[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&focusedCommentId=16179293#comment-16179293 ] Peter Davis commented on KAFKA-5970: Thanks [~rsivaram] and [~hachikuji] for looking 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&focusedCommentId=16179184#comment-16179184 ] Peter Davis commented on KAFKA-5970: [~rsivaram] Thanks for looking into this so quick

[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&focusedCommentId=16179159#comment-16179159 ] Peter Davis commented on KAFKA-5970: I ended up here because of commonality of deadloc

[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&focusedCommentId=16179141#comment-16179141 ] Peter Davis commented on KAFKA-5970: It looks like we are seeing this repeatedly in a

[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&focusedCommentId=16145648#comment-16145648 ] Peter Davis edited comment on KAFKA-2729 at 8/29/17 5:27 PM: -

[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&focusedCommentId=16145731#comment-16145731 ] Peter Davis commented on KAFKA-4674: Duplicate of KAFKA-2729? > Frequent ISR shrinkin

[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&focusedCommentId=16145648#comment-16145648 ] Peter Davis edited comment on KAFKA-2729 at 8/29/17 4:48 PM: -

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

[jira] [Commented] (KAFKA-4602) KIP-72 Allow putting a bound on memory consumed by Incoming requests

[ https://issues.apache.org/jira/browse/KAFKA-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051313#comment-16051313 ] Peter Davis commented on KAFKA-4602: Does this address increased memory used by decomp

[jira] [Updated] (KAFKA-4602) KIP-72 Allow putting a bound on memory consumed by Incoming requests

[ https://issues.apache.org/jira/browse/KAFKA-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Davis updated KAFKA-4602: --- Attachment: screenshot-1.png > KIP-72 Allow putting a bound on memory consumed by Incoming requests >