[jira] [Created] (KAFKA-8921) Avoid excessive info logs in the client side for incremental fetch

Zhanxiang (Patrick) Huang created KAFKA-8921: Summary: Avoid excessive info logs in the client side for incremental fetch Key: KAFKA-8921 URL: https://issues.apache.org/jira/browse/KAFKA-8921

[jira] [Assigned] (KAFKA-8202) StackOverflowError on producer when splitting batches

[ https://issues.apache.org/jira/browse/KAFKA-8202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang reassigned KAFKA-8202: Assignee: Zhanxiang (Patrick) Huang > StackOverflowError on produc

[jira] [Created] (KAFKA-8668) Improve broker shutdown time

Zhanxiang (Patrick) Huang created KAFKA-8668: Summary: Improve broker shutdown time Key: KAFKA-8668 URL: https://issues.apache.org/jira/browse/KAFKA-8668 Project: Kafka Issue Type

[jira] [Created] (KAFKA-8667) Improve leadership transition time

Zhanxiang (Patrick) Huang created KAFKA-8667: Summary: Improve leadership transition time Key: KAFKA-8667 URL: https://issues.apache.org/jira/browse/KAFKA-8667 Project: Kafka Issu

[jira] [Created] (KAFKA-8571) Not complete delayed produce requests when processing StopReplicaRequest causing high produce latency for acks=all

Zhanxiang (Patrick) Huang created KAFKA-8571: Summary: Not complete delayed produce requests when processing StopReplicaRequest causing high produce latency for acks=all Key: KAFKA-8571 URL: https://is

[jira] [Created] (KAFKA-8069) Committed offsets get cleaned up right after the coordinator loading them back from __consumer_offsets in broker with old inter-broker protocol version (< 2.2)

Zhanxiang (Patrick) Huang created KAFKA-8069: Summary: Committed offsets get cleaned up right after the coordinator loading them back from __consumer_offsets in broker with old inter-broker protocol version (< 2.2) Ke

[jira] [Updated] (KAFKA-8069) Committed offsets get cleaned up right after the coordinator loading them back from __consumer_offsets in broker with old inter-broker protocol version (< 2.2)

[ https://issues.apache.org/jira/browse/KAFKA-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang updated KAFKA-8069: - Affects Version/s: 2.2.1 2.1.2

[jira] [Created] (KAFKA-8066) ReplicaFetcherThread fails to startup because of failing to register the metric.

Zhanxiang (Patrick) Huang created KAFKA-8066: Summary: ReplicaFetcherThread fails to startup because of failing to register the metric. Key: KAFKA-8066 URL: https://issues.apache.org/jira/browse/KAFKA-

[jira] [Updated] (KAFKA-8066) ReplicaFetcherThread fails to startup because of failing to register the metric.

[ https://issues.apache.org/jira/browse/KAFKA-8066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang updated KAFKA-8066: - Affects Version/s: 2.1.2 2.0.2

[jira] [Created] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0

Zhanxiang (Patrick) Huang created KAFKA-7854: Summary: Behavior change in controller picking up partition reassignment tasks since 1.1.0 Key: KAFKA-7854 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Commented] (KAFKA-7297) Both read/write access to Log.segments should be protected by lock

[ https://issues.apache.org/jira/browse/KAFKA-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741921#comment-16741921 ] Zhanxiang (Patrick) Huang commented on KAFKA-7297: -- Sorry for being late

[jira] [Assigned] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang reassigned KAFKA-6029: Assignee: Zhanxiang (Patrick) Huang > Controller should wait for t

[jira] [Resolved] (KAFKA-7452) Deleting snapshot files after check-pointing log recovery offsets can slow down replication when truncation happens

[ https://issues.apache.org/jira/browse/KAFKA-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang resolved KAFKA-7452. -- Resolution: Duplicate KAFKA-7557 fixed this. > Deleting snapshot files

[jira] [Created] (KAFKA-7537) Only include live brokers in the UpdateMetadataRequest sent to existing brokers if there is no change in the partition states

Zhanxiang (Patrick) Huang created KAFKA-7537: Summary: Only include live brokers in the UpdateMetadataRequest sent to existing brokers if there is no change in the partition states Key: KAFKA-7537 URL:

[jira] [Commented] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16652396#comment-16652396 ] Zhanxiang (Patrick) Huang commented on KAFKA-7464: -- [~ijuma]  I was wai

[jira] [Commented] (KAFKA-6051) ReplicaFetcherThread should close the ReplicaFetcherBlockingSend earlier on shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16634331#comment-16634331 ] Zhanxiang (Patrick) Huang commented on KAFKA-6051: -- [~ijuma] Sure. I ha

[jira] [Created] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

Zhanxiang (Patrick) Huang created KAFKA-7464: Summary: Fail to shutdown ReplicaManager during broker cleaned shutdown Key: KAFKA-7464 URL: https://issues.apache.org/jira/browse/KAFKA-7464

[jira] [Created] (KAFKA-7459) Concurrency bug in updating RequestsPerSec metric

Zhanxiang (Patrick) Huang created KAFKA-7459: Summary: Concurrency bug in updating RequestsPerSec metric Key: KAFKA-7459 URL: https://issues.apache.org/jira/browse/KAFKA-7459 Project: Kafk

[jira] [Updated] (KAFKA-7459) Concurrency bug in updating RequestsPerSec metric

[ https://issues.apache.org/jira/browse/KAFKA-7459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang updated KAFKA-7459: - Priority: Critical (was: Major) > Concurrency bug in updating RequestsPe

[jira] [Comment Edited] (KAFKA-6051) ReplicaFetcherThread should close the ReplicaFetcherBlockingSend earlier on shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16632280#comment-16632280 ] Zhanxiang (Patrick) Huang edited comment on KAFKA-6051 at 9/28/18 7:23 PM:

[jira] [Commented] (KAFKA-6051) ReplicaFetcherThread should close the ReplicaFetcherBlockingSend earlier on shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16632280#comment-16632280 ] Zhanxiang (Patrick) Huang commented on KAFKA-6051: -- [~mchinavan] [~junr

[jira] [Assigned] (KAFKA-7452) Deleting snapshot files after check-pointing log recovery offsets can slow down replication when truncation happens

[ https://issues.apache.org/jira/browse/KAFKA-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang reassigned KAFKA-7452: Assignee: Zhanxiang (Patrick) Huang > Deleting snapshot files afte

[jira] [Created] (KAFKA-7452) Deleting snapshot files after check-pointing log recovery offsets can slow down replication when truncation happens

Zhanxiang (Patrick) Huang created KAFKA-7452: Summary: Deleting snapshot files after check-pointing log recovery offsets can slow down replication when truncation happens Key: KAFKA-7452 URL: https://i

[jira] [Commented] (KAFKA-7235) Use brokerZkNodeVersion to prevent broker from processing outdated controller request

[ https://issues.apache.org/jira/browse/KAFKA-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618368#comment-16618368 ] Zhanxiang (Patrick) Huang commented on KAFKA-7235: -- We cannot simply use

[jira] [Assigned] (KAFKA-7235) Use brokerZkNodeVersion to prevent broker from processing outdated controller request

[ https://issues.apache.org/jira/browse/KAFKA-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang reassigned KAFKA-7235: Assignee: Zhanxiang (Patrick) Huang (was: Dong Lin) > Use brokerZ

[jira] [Created] (KAFKA-7283) mmap indexes lazily and skip sanity check for segments below recovery point

Zhanxiang (Patrick) Huang created KAFKA-7283: Summary: mmap indexes lazily and skip sanity check for segments below recovery point Key: KAFKA-7283 URL: https://issues.apache.org/jira/browse/KAFKA-7283

[jira] [Assigned] (KAFKA-7152) replica should be in-sync if its LEO equals leader's LEO

[ https://issues.apache.org/jira/browse/KAFKA-7152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang reassigned KAFKA-7152: Assignee: Zhanxiang (Patrick) Huang (was: Dong Lin) > replica sho

[jira] [Created] (KAFKA-7186) Controller uses too much memory when sending out UpdateMetadataRequest that can cause OutOfMemoryError

Zhanxiang (Patrick) Huang created KAFKA-7186: Summary: Controller uses too much memory when sending out UpdateMetadataRequest that can cause OutOfMemoryError Key: KAFKA-7186 URL: https://issues.apache.

[jira] [Assigned] (KAFKA-6082) consider fencing zookeeper updates with controller epoch zkVersion

[ https://issues.apache.org/jira/browse/KAFKA-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang reassigned KAFKA-6082: Assignee: Zhanxiang (Patrick) Huang > consider fencing zookeeper u