[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 time

[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] [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

Re: Message conversion and TLS

2023-02-23 Thread David Mao
My understanding of the produce message conversions metric is that the metric is specifically for message format up-conversion which is independent of TLS being enabled. It’s also worth noting that the zero-copy sendfile is not used on the produce path, only the fetch path. On Thu, Feb 23, 2023 a

[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] [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 Type

[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] [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 Type

Re: [DISCUSS] KIP-714: Client metrics and observability

2021-11-04 Thread David Mao
Hey Magnus, I noticed that the KIP outlines the initial selectors supported as: - client_instance_id - CLIENT_INSTANCE_ID UUID string representation. - client_software_name - client software implementation name. - client_software_version - client software implementation version. In th

[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] [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-23 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

Re: Failed Unit testings in ReassignPartitionsIntegrationTest

2021-08-20 Thread David Mao
This assertion doesn't seem safe. I opened a PR for a fix. Do you mind taking a look, Luke? David On Thu, Aug 19, 2021 at 12:29 AM Yanwen Lin wrote: > Hi Luke, > > Thanks for your suggestion! I will try to test in in VM/Docker. > > BTW, may I know the exact java/scala version used in your local

Re: [DISCUSS] KIP-764 Configurable backlog size for creating Acceptor

2021-08-09 Thread David Mao
Hi Haruki, I think it makes sense to have this as a configurable property. I think we should name the property socket.listen.backlog.size for better clarity on what the property configures. Besides that, the proposal looks good to me. David On Wed, Jul 28, 2021 at 8:09 AM Haruki Okada wrote: >

[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 r

[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] [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] [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

Re: [VOTE] KIP-612: Ability to Limit Connection Creation Rate on Brokers

2020-11-06 Thread David Mao
per-IP quotas. Let me know if there are any questions/concerns. Thanks David (Mao) On 2020/11/03 21:04:37, Anna Povzner wrote: > Hi David,> > > You are right, using a token bucket exposes the metric for the number of> > remaining tokens in the bucket. Since we also want t

[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

Confluence edit permissions

2020-11-06 Thread David Mao
Hi all, I'd like to make an update to a KIP, can I get edit permissions for Confluence? Thanks, David

[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 Type