[jira] [Commented] (KAFKA-3720) Remove BufferExhaustException from doSend() in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072089#comment-17072089 ] Mayuresh Gharat commented on KAFKA-3720: You can take this up. Thanks, Mayuresh

[jira] [Commented] (KAFKA-4453) add request prioritization

[ https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16739822#comment-16739822 ] Mayuresh Gharat commented on KAFKA-4453: Hi [~sriharsha], Yes, the PR is already

[jira] [Commented] (KAFKA-7728) Add JoinReason to the join group request for better rebalance handling

[ https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725512#comment-16725512 ] Mayuresh Gharat commented on KAFKA-7728: To shed more light on this : As per the

[jira] [Commented] (KAFKA-7681) new metric for request thread utilization by request type

[ https://issues.apache.org/jira/browse/KAFKA-7681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16718138#comment-16718138 ] Mayuresh Gharat commented on KAFKA-7681: Hi [~junrao], # IIUC, After inspecting

[jira] [Comment Edited] (KAFKA-7681) new metric for request thread utilization by request type

[ https://issues.apache.org/jira/browse/KAFKA-7681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16718138#comment-16718138 ] Mayuresh Gharat edited comment on KAFKA-7681 at 12/11/18 10:57 PM:

[jira] [Comment Edited] (KAFKA-7681) new metric for request thread utilization by request type

[ https://issues.apache.org/jira/browse/KAFKA-7681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16718138#comment-16718138 ] Mayuresh Gharat edited comment on KAFKA-7681 at 12/11/18 10:56 PM:

[jira] [Commented] (KAFKA-7681) new metric for request thread utilization by request type

[ https://issues.apache.org/jira/browse/KAFKA-7681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16715264#comment-16715264 ] Mayuresh Gharat commented on KAFKA-7681: [~junrao] will try to give a shot at thi

[jira] [Assigned] (KAFKA-7681) new metric for request thread utilization by request type

[ https://issues.apache.org/jira/browse/KAFKA-7681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat reassigned KAFKA-7681: -- Assignee: Mayuresh Gharat > new metric for request thread utilization by request type

[jira] [Commented] (KAFKA-7681) new metric for request thread utilization by request type

[ https://issues.apache.org/jira/browse/KAFKA-7681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701387#comment-16701387 ] Mayuresh Gharat commented on KAFKA-7681: Hi [~junrao], This seems more like the

[jira] [Updated] (KAFKA-4453) add request prioritization

[ https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-4453: --- Issue Type: Improvement (was: Bug) > add request prioritization > --

[jira] [Commented] (KAFKA-7546) Java implementation for Authorizer

[ https://issues.apache.org/jira/browse/KAFKA-7546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670335#comment-16670335 ] Mayuresh Gharat commented on KAFKA-7546: [~bansalp], I believe that would depend

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: Today when we call KafkaConsumer.poll(), it will fetch data from Kafka asynchro

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: In KafkaConsumer, when we do a poll, we fetch data asynchronously from kafka br

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: In KafkaConsumer, when we do a poll, we fetch data asynchronously from kafka br

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: In KafkaConsumer, when we do a poll, we fetch data asynchronously from kafka br

[jira] [Commented] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665433#comment-16665433 ] Mayuresh Gharat commented on KAFKA-7556: One more question, did you try this with

[jira] [Commented] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665428#comment-16665428 ] Mayuresh Gharat commented on KAFKA-7556: Hi [~rob_v], This seems like a bug to m

[jira] [Commented] (KAFKA-7546) Java implementation for Authorizer

[ https://issues.apache.org/jira/browse/KAFKA-7546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663321#comment-16663321 ] Mayuresh Gharat commented on KAFKA-7546: Hi [~bansalp],   Kafka Provides Author

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: In KafkaConsumer, when we do a poll, we fetch data asynchronously from kafka br

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: In KafkaConsumer, when we do a poll, we fetch data asynchronously from kafka br

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: In KafkaConsumer, when we do a poll, we fetch data asynchronously from kafka br

[jira] [Created] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

Mayuresh Gharat created KAFKA-7548: -- Summary: KafkaConsumer should not throw away already fetched data for paused partitions. Key: KAFKA-7548 URL: https://issues.apache.org/jira/browse/KAFKA-7548 Pro

[jira] [Commented] (KAFKA-7096) Consumer should drop the data for unassigned topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-7096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16522768#comment-16522768 ] Mayuresh Gharat commented on KAFKA-7096: [~lindong] : [https://github.com/apache/

[jira] [Created] (KAFKA-7096) Consumer should drop the data for unassigned topic partitions

Mayuresh Gharat created KAFKA-7096: -- Summary: Consumer should drop the data for unassigned topic partitions Key: KAFKA-7096 URL: https://issues.apache.org/jira/browse/KAFKA-7096 Project: Kafka

[jira] [Assigned] (KAFKA-4433) Kafka Controller Does not send a LeaderAndIsr to old leader of a topicPartition during reassignment, if the old leader is not a part of the new assigned replicas

[ https://issues.apache.org/jira/browse/KAFKA-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat reassigned KAFKA-4433: -- Assignee: (was: Mayuresh Gharat) > Kafka Controller Does not send a LeaderAndIsr t