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
[
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
>
[
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
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
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
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
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
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
[
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
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:
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
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
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
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
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
[
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
>
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
[
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
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:
[
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
[
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
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
[
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
[
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
[
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
>
[
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]
[
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]
[
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
[
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]
[
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
[
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
[
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
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
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:
[
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
>
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
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
[
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
[
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
[
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
[
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
[
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
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
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
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:
[
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
>
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
[
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
[
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
[
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
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
[
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
>
[
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
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
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
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
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
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
>
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
[
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
>
[
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
[
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
[
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
[
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
>
[
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
[
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
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
74 matches
Mail list logo