[jira] [Created] (KAFKA-16571) reassign_partitions_test.bounce_brokers should wait for messages to be sent to every partition

2024-04-16 Thread David Mao (Jira)
David Mao created KAFKA-16571: - Summary: reassign_partitions_test.bounce_brokers should wait for messages to be sent to every partition Key: KAFKA-16571 URL: https://issues.apache.org/jira/browse/KAFKA-16571

[jira] [Resolved] (KAFKA-16395) Producer should refresh metadata on a socket request timeout

2024-03-20 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao resolved KAFKA-16395. --- Resolution: Not A Bug > Producer should refresh metadata on a socket request timeout >

[jira] [Commented] (KAFKA-16395) Producer should refresh metadata on a socket request timeout

2024-03-20 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829311#comment-17829311 ] David Mao commented on KAFKA-16395: --- on a closer reading, I believe I misunderstood the code in

[jira] [Created] (KAFKA-16395) Producer should refresh metadata on a socket request timeout

2024-03-20 Thread David Mao (Jira)
David Mao created KAFKA-16395: - Summary: Producer should refresh metadata on a socket request timeout Key: KAFKA-16395 URL: https://issues.apache.org/jira/browse/KAFKA-16395 Project: Kafka

[jira] [Created] (KAFKA-16121) Partition reassignments in ZK migration dual write mode stalled until leader epoch incremented

2024-01-12 Thread David Mao (Jira)
David Mao created KAFKA-16121: - Summary: Partition reassignments in ZK migration dual write mode stalled until leader epoch incremented Key: KAFKA-16121 URL: https://issues.apache.org/jira/browse/KAFKA-16121

[jira] [Created] (KAFKA-16120) Partition reassignments in ZK migration dual write leaves stray partitions

2024-01-12 Thread David Mao (Jira)
David Mao created KAFKA-16120: - Summary: Partition reassignments in ZK migration dual write leaves stray partitions Key: KAFKA-16120 URL: https://issues.apache.org/jira/browse/KAFKA-16120 Project: Kafka

[jira] [Created] (KAFKA-15780) Wait for consistent kraft metadata when creating topics in tests

2023-11-02 Thread David Mao (Jira)
David Mao created KAFKA-15780: - Summary: Wait for consistent kraft metadata when creating topics in tests Key: KAFKA-15780 URL: https://issues.apache.org/jira/browse/KAFKA-15780 Project: Kafka

[jira] [Created] (KAFKA-15526) Simplify LogAppendInfo parameters

2023-10-02 Thread David Mao (Jira)
David Mao created KAFKA-15526: - Summary: Simplify LogAppendInfo parameters Key: KAFKA-15526 URL: https://issues.apache.org/jira/browse/KAFKA-15526 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-15344) Kafka Streams should include the message leader epoch when committing offsets

2023-08-15 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-15344: -- Description: We noticed an application received an OFFSET_OUT_OF_RANGE error following a network

[jira] [Created] (KAFKA-15344) Kafka Streams should include the message leader epoch when committing offsets

2023-08-15 Thread David Mao (Jira)
David Mao created KAFKA-15344: - Summary: Kafka Streams should include the message leader epoch when committing offsets Key: KAFKA-15344 URL: https://issues.apache.org/jira/browse/KAFKA-15344 Project:

[jira] [Created] (KAFKA-15220) KRaftMetadataCache returns fenced brokers from getAliveBrokerNode

2023-07-19 Thread David Mao (Jira)
David Mao created KAFKA-15220: - Summary: KRaftMetadataCache returns fenced brokers from getAliveBrokerNode Key: KAFKA-15220 URL: https://issues.apache.org/jira/browse/KAFKA-15220 Project: Kafka

[jira] [Created] (KAFKA-15192) Network thread receives exception when updating request metrics

2023-07-14 Thread David Mao (Jira)
David Mao created KAFKA-15192: - Summary: Network thread receives exception when updating request metrics Key: KAFKA-15192 URL: https://issues.apache.org/jira/browse/KAFKA-15192 Project: Kafka

[jira] [Created] (KAFKA-15044) Snappy v.1.1.9.1 NoClassDefFound on ARM machines

2023-05-31 Thread David Mao (Jira)
David Mao created KAFKA-15044: - Summary: Snappy v.1.1.9.1 NoClassDefFound on ARM machines Key: KAFKA-15044 URL: https://issues.apache.org/jira/browse/KAFKA-15044 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-14990) Dynamic producer ID expiration is not applied on broker restart

2023-05-11 Thread David Mao (Jira)
David Mao created KAFKA-14990: - Summary: Dynamic producer ID expiration is not applied on broker restart Key: KAFKA-14990 URL: https://issues.apache.org/jira/browse/KAFKA-14990 Project: Kafka

[jira] [Created] (KAFKA-14295) FetchMessageConversionsPerSec meter not recorded

2022-10-12 Thread David Mao (Jira)
David Mao created KAFKA-14295: - Summary: FetchMessageConversionsPerSec meter not recorded Key: KAFKA-14295 URL: https://issues.apache.org/jira/browse/KAFKA-14295 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-14144) AlterPartition is not idempotent when requests time out

2022-08-04 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-14144: -- Affects Version/s: 3.3.0 > AlterPartition is not idempotent when requests time out >

[jira] [Created] (KAFKA-14144) AlterPartition is not idempotent when requests time out

2022-08-04 Thread David Mao (Jira)
David Mao created KAFKA-14144: - Summary: AlterPartition is not idempotent when requests time out Key: KAFKA-14144 URL: https://issues.apache.org/jira/browse/KAFKA-14144 Project: Kafka Issue

[jira] [Updated] (KAFKA-14025) Request timeout includes time queued per connection

2022-06-26 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-14025: -- Description: In the NetworkClient we measure request timeouts from when a request is first queued in 

[jira] [Created] (KAFKA-14025) Request timeout includes time queued per connection

2022-06-26 Thread David Mao (Jira)
David Mao created KAFKA-14025: - Summary: Request timeout includes time queued per connection Key: KAFKA-14025 URL: https://issues.apache.org/jira/browse/KAFKA-14025 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-13623) Memory leak when multiple poll

2022-01-30 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484366#comment-17484366 ] David Mao edited comment on KAFKA-13623 at 1/30/22, 2:40 PM: - direct memory

[jira] [Commented] (KAFKA-13623) Memory leak when multiple poll

2022-01-30 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484366#comment-17484366 ] David Mao commented on KAFKA-13623: --- Can you add *-XX:+HeapDumpOnOutOfMemoryError* to the consumer

[jira] [Created] (KAFKA-13614) Leader replication quota is applied to consumer fetches

2022-01-24 Thread David Mao (Jira)
David Mao created KAFKA-13614: - Summary: Leader replication quota is applied to consumer fetches Key: KAFKA-13614 URL: https://issues.apache.org/jira/browse/KAFKA-13614 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-12-10 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457216#comment-17457216 ] David Mao edited comment on KAFKA-13388 at 12/10/21, 4:43 PM: -- We should

[jira] [Commented] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-12-10 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457216#comment-17457216 ] David Mao commented on KAFKA-13388: --- We should probably bump up the priority of this Jira to Major or

[jira] [Updated] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-12-10 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-13388: -- Priority: Critical (was: Minor) > Kafka Producer nodes stuck in CHECKING_API_VERSIONS >

[jira] [Comment Edited] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-12-09 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456854#comment-17456854 ] David Mao edited comment on KAFKA-13388 at 12/10/21, 2:10 AM: -- [~dhofftgt] 

[jira] [Comment Edited] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-12-09 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456854#comment-17456854 ] David Mao edited comment on KAFKA-13388 at 12/10/21, 1:56 AM: -- [~dhofftgt] 

[jira] [Commented] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-12-09 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456854#comment-17456854 ] David Mao commented on KAFKA-13388: --- [~dhofftgt]  Looking at where the NetworkClient enters the

[jira] [Comment Edited] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-11-05 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439526#comment-17439526 ] David Mao edited comment on KAFKA-13388 at 11/5/21, 10:20 PM: -- [~dhofftgt]

[jira] [Commented] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-11-05 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439526#comment-17439526 ] David Mao commented on KAFKA-13388: --- [~dhofftgt] Why do we expect a connection in

[jira] [Commented] (KAFKA-13360) Wrong SSL messages when handshake fails

2021-10-08 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426334#comment-17426334 ] David Mao commented on KAFKA-13360: --- Very thorough writeup, nice find! > Wrong SSL messages when

[jira] [Updated] (KAFKA-13354) Topic metrics count request rate inconsistently with other request metrics

2021-10-06 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-13354: -- Description: The request rate metrics in BrokerTopicMetrics are incremented per partition in a

[jira] [Created] (KAFKA-13354) Topic metrics count request rate inconsistently with other request metrics

2021-10-06 Thread David Mao (Jira)
David Mao created KAFKA-13354: - Summary: Topic metrics count request rate inconsistently with other request metrics Key: KAFKA-13354 URL: https://issues.apache.org/jira/browse/KAFKA-13354 Project: Kafka

[jira] [Created] (KAFKA-13341) Quotas are not applied to requests with null clientId

2021-10-03 Thread David Mao (Jira)
David Mao created KAFKA-13341: - Summary: Quotas are not applied to requests with null clientId Key: KAFKA-13341 URL: https://issues.apache.org/jira/browse/KAFKA-13341 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-13341) Quotas are not applied to requests with null clientId

2021-10-03 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-13341: -- Priority: Major (was: Minor) > Quotas are not applied to requests with null clientId >

[jira] [Created] (KAFKA-13314) Pluggable components initialized with getConfiguredInstance do not respect dynamic config updates

2021-09-21 Thread David Mao (Jira)
David Mao created KAFKA-13314: - Summary: Pluggable components initialized with getConfiguredInstance do not respect dynamic config updates Key: KAFKA-13314 URL: https://issues.apache.org/jira/browse/KAFKA-13314

[jira] [Created] (KAFKA-13225) Controller skips sending UpdateMetadataRequest when shutting down broker doesnt host partitions

2021-08-24 Thread David Mao (Jira)
David Mao created KAFKA-13225: - Summary: Controller skips sending UpdateMetadataRequest when shutting down broker doesnt host partitions Key: KAFKA-13225 URL: https://issues.apache.org/jira/browse/KAFKA-13225

[jira] [Comment Edited] (KAFKA-13135) Reduce GroupMetadata lock contention for offset commit requests

2021-07-25 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387028#comment-17387028 ] David Mao edited comment on KAFKA-13135 at 7/26/21, 4:18 AM: - Taking a

[jira] [Comment Edited] (KAFKA-13135) Reduce GroupMetadata lock contention for offset commit requests

2021-07-25 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387028#comment-17387028 ] David Mao edited comment on KAFKA-13135 at 7/26/21, 3:48 AM: - Taking a

[jira] [Comment Edited] (KAFKA-13135) Reduce GroupMetadata lock contention for offset commit requests

2021-07-25 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387028#comment-17387028 ] David Mao edited comment on KAFKA-13135 at 7/26/21, 3:43 AM: - Taking a

[jira] [Comment Edited] (KAFKA-13135) Reduce GroupMetadata lock contention for offset commit requests

2021-07-25 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387028#comment-17387028 ] David Mao edited comment on KAFKA-13135 at 7/26/21, 3:42 AM: - Taking a

[jira] [Commented] (KAFKA-13135) Reduce GroupMetadata lock contention for offset commit requests

2021-07-25 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387028#comment-17387028 ] David Mao commented on KAFKA-13135: --- Taking a closer look, I think we can also optimize this for the

[jira] [Created] (KAFKA-13135) Reduce GroupMetadata lock contention for offset commit requests

2021-07-25 Thread David Mao (Jira)
David Mao created KAFKA-13135: - Summary: Reduce GroupMetadata lock contention for offset commit requests Key: KAFKA-13135 URL: https://issues.apache.org/jira/browse/KAFKA-13135 Project: Kafka

[jira] [Created] (KAFKA-13134) Heartbeat Request high lock contention

2021-07-25 Thread David Mao (Jira)
David Mao created KAFKA-13134: - Summary: Heartbeat Request high lock contention Key: KAFKA-13134 URL: https://issues.apache.org/jira/browse/KAFKA-13134 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-12986) Throttled Replicas validator should validate that the proposed value is parseable

2021-06-23 Thread David Mao (Jira)
David Mao created KAFKA-12986: - Summary: Throttled Replicas validator should validate that the proposed value is parseable Key: KAFKA-12986 URL: https://issues.apache.org/jira/browse/KAFKA-12986 Project:

[jira] [Resolved] (KAFKA-10749) Add throttling of IPs by connection rate

2021-03-22 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao resolved KAFKA-10749. --- Resolution: Fixed > Add throttling of IPs by connection rate >

[jira] [Created] (KAFKA-12427) Broker does not close muted idle connections with buffered data

2021-03-04 Thread David Mao (Jira)
David Mao created KAFKA-12427: - Summary: Broker does not close muted idle connections with buffered data Key: KAFKA-12427 URL: https://issues.apache.org/jira/browse/KAFKA-12427 Project: Kafka

[jira] [Updated] (KAFKA-10024) Add dynamic configuration and enforce quota for per-IP connection rate limits (KIP-612, part 2)

2020-11-19 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10024: -- Parent: KAFKA-10749 Issue Type: Sub-task (was: Improvement) > Add dynamic configuration and

[jira] [Updated] (KAFKA-10748) Add IP connection rate throttling metric

2020-11-19 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10748: -- Parent: KAFKA-10749 Issue Type: Sub-task (was: Improvement) > Add IP connection rate

[jira] [Updated] (KAFKA-10747) Implement ClientQuota APIs for altering and describing IP entity quotas

2020-11-19 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10747: -- Parent: KAFKA-10749 Issue Type: Sub-task (was: Improvement) > Implement ClientQuota APIs for

[jira] [Created] (KAFKA-10749) Add throttling of IPs by connection rate

2020-11-19 Thread David Mao (Jira)
David Mao created KAFKA-10749: - Summary: Add throttling of IPs by connection rate Key: KAFKA-10749 URL: https://issues.apache.org/jira/browse/KAFKA-10749 Project: Kafka Issue Type: New Feature

[jira] [Updated] (KAFKA-10748) Add IP connection rate throttling metric

2020-11-19 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10748: -- Component/s: network core > Add IP connection rate throttling metric >

[jira] [Updated] (KAFKA-10747) Implement ClientQuota APIs for altering and describing IP entity quotas

2020-11-19 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10747: -- Component/s: core config > Implement ClientQuota APIs for altering and describing IP

[jira] [Created] (KAFKA-10748) Add IP connection rate throttling metric

2020-11-19 Thread David Mao (Jira)
David Mao created KAFKA-10748: - Summary: Add IP connection rate throttling metric Key: KAFKA-10748 URL: https://issues.apache.org/jira/browse/KAFKA-10748 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-10747) Implement ClientQuota APIs for altering and describing IP entity quotas

2020-11-19 Thread David Mao (Jira)
David Mao created KAFKA-10747: - Summary: Implement ClientQuota APIs for altering and describing IP entity quotas Key: KAFKA-10747 URL: https://issues.apache.org/jira/browse/KAFKA-10747 Project: Kafka

[jira] [Created] (KAFKA-10744) Listener and broker connection rate quota tests should use mock time

2020-11-18 Thread David Mao (Jira)
David Mao created KAFKA-10744: - Summary: Listener and broker connection rate quota tests should use mock time Key: KAFKA-10744 URL: https://issues.apache.org/jira/browse/KAFKA-10744 Project: Kafka

[jira] [Created] (KAFKA-10695) Improve interface for sensor expiration

2020-11-07 Thread David Mao (Jira)
David Mao created KAFKA-10695: - Summary: Improve interface for sensor expiration Key: KAFKA-10695 URL: https://issues.apache.org/jira/browse/KAFKA-10695 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-10693) Tests instantiate QuotaManagers without closing the managers in teardown

2020-11-06 Thread David Mao (Jira)
David Mao created KAFKA-10693: - Summary: Tests instantiate QuotaManagers without closing the managers in teardown Key: KAFKA-10693 URL: https://issues.apache.org/jira/browse/KAFKA-10693 Project: Kafka

[jira] [Updated] (KAFKA-10673) ConnectionQuotas should cache interbroker listener name

2020-11-03 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10673: -- Description: ConnectionQuotas.protectedListener calls config.interBrokerListenerName. This is a

[jira] [Updated] (KAFKA-10673) ConnectionQuotas should cache interbroker listener name

2020-11-03 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10673: -- Description: ConnectionQuotas.protectedListener calls `config.interBrokerListenerName`. This is a

[jira] [Updated] (KAFKA-10673) ConnectionQuotas should cache interbroker listener name

2020-11-03 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10673: -- Description: ConnectionQuotas.protectedListener calls `config.interBrokerListenerName`. This is a

[jira] [Updated] (KAFKA-10673) ConnectionQuotas should cache interbroker listener name

2020-11-03 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10673: -- Description: !Screen Shot 2020-11-03 at 8.34.48 PM.png! ConnectionQuotas.protectedListener calls

[jira] [Updated] (KAFKA-10673) ConnectionQuotas should cache interbroker listener name

2020-11-03 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10673: -- Attachment: Screen Shot 2020-11-03 at 8.34.48 PM.png > ConnectionQuotas should cache interbroker

[jira] [Updated] (KAFKA-10673) ConnectionQuotas should cache interbroker listener name

2020-11-03 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10673: -- Description: ConnectionQuotas.protectedListener calls `config.interBrokerListenerName`. This is a

[jira] [Updated] (KAFKA-10673) ConnectionQuotas should cache interbroker listener name

2020-11-03 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-10673: -- Priority: Minor (was: Major) > ConnectionQuotas should cache interbroker listener name >

[jira] [Created] (KAFKA-10673) ConnectionQuotas should cache interbroker listener name

2020-11-02 Thread David Mao (Jira)
David Mao created KAFKA-10673: - Summary: ConnectionQuotas should cache interbroker listener name Key: KAFKA-10673 URL: https://issues.apache.org/jira/browse/KAFKA-10673 Project: Kafka Issue

[jira] [Assigned] (KAFKA-9189) Shutdown is blocked if connection to Zookeeper is lost

2020-06-10 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao reassigned KAFKA-9189: Assignee: David Mao > Shutdown is blocked if connection to Zookeeper is lost >

[jira] [Commented] (KAFKA-9189) Shutdown is blocked if connection to Zookeeper is lost

2020-04-13 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082642#comment-17082642 ] David Mao commented on KAFKA-9189: -- also observed this issue, took a thread-dump and found that

[jira] [Assigned] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is invali

2020-02-10 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao reassigned KAFKA-6266: Assignee: David Mao (was: Anna Povzner) > Kafka 1.0.0 : Repeated occurrence of WARN Resetting

[jira] [Commented] (KAFKA-9507) AdminClient should check for missing committed offsets

2020-02-06 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032026#comment-17032026 ] David Mao commented on KAFKA-9507: -- [https://github.com/apache/kafka/pull/8057] Pull request to address

[jira] [Assigned] (KAFKA-9507) AdminClient should check for missing committed offsets

2020-02-06 Thread David Mao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao reassigned KAFKA-9507: Assignee: David Mao > AdminClient should check for missing committed offsets >

[jira] [Updated] (KAFKA-8583) Optimization for SslTransportLayer#write(ByteBuffer)

2019-06-21 Thread Mao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mao updated KAFKA-8583: --- Description: The is a propose to optimize SslTransportLayer#write(ByteBuffer). Currently, sslEngine only reads data

[jira] [Updated] (KAFKA-8583) Optimization for SslTransportLayer#write(ByteBuffer)

2019-06-21 Thread Mao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mao updated KAFKA-8583: --- Description: The is a propose to optimize SslTransportLayer#write(ByteBuffer). Currently, sslEngine only reads data

[jira] [Created] (KAFKA-8583) Optimization for SslTransportLayer#write(ByteBuffer)

2019-06-21 Thread Mao (JIRA)
Mao created KAFKA-8583: -- Summary: Optimization for SslTransportLayer#write(ByteBuffer) Key: KAFKA-8583 URL: https://issues.apache.org/jira/browse/KAFKA-8583 Project: Kafka Issue Type: Improvement