kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
KAFKA-13559: Fix issue where responses intermittently takes 300+ ms to respond, even when the server is idle. Processing request got delayed by 300 ms in the following condition: 1. Client-Server...
Changes for [KIP-854](https://cwiki.apache.org/confluence/display/KAFKA/KIP-854+Separate+configuration+for+producer+ID+expiry) We add the producer id expiration configuration and a test. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ]...
*More detailed description of your change* The reason for KAFKA-13959 is a little complex, the two keys to this problem are: 1. `KafkaRaftClient.MAX_FETCH_WAIT_MS==MetadataMaxIdleIntervalMs == 500ms`. We rely on fetchPurgatory to...
Converting DeleteTopicTest, DeleteTopicsRequestWithDeletionDisabledTest, and RackAwareAutoTopicCreationTest to run in KRaft mode. Added unit tests to StripedReplicaPlacerTest to ensure even leadership distribution (at least for large number of partitions). ### Committer Checklist...
This implements KIP-830: https://cwiki.apache.org/confluence/display/KAFKA/KIP-830%3A+Allow+disabling+JMX+Reporter It adds a new configuration jmx.reporter.enable that can be set to false to disable the JMX Reporter ### Committer Checklist (excluded from commit message) - [...
KAFKA-14147: Prevent deferredTaskUpdates map from growing monotonically in KafkaConfigBackingStore
- https://issues.apache.org/jira/browse/KAFKA-14147 - Similar to https://issues.apache.org/jira/browse/KAFKA-8869, but without the rebalancing implications.
Batch 2 of the tests detailed in https://issues.apache.org/jira/browse/KAFKA-14133 which use EasyMock and need to be moved to Mockito.
@mumrah @cmccabe It looks like a way to fix `DynamicBrokerReconfigurationTest` in 3.2 is to backport https://github.com/apache/kafka/commit/9c3f605fc78f297ecf5accdcdec18471c19cf7d6. I think it makes sense to to also backport https://github.com/apache/kafka/commit/78038bca6688ce01f7df238d53142f5de3455863, otherwise `testKeyStoreAlter()` is really...
This PR implements the follower fetch protocol as mentioned in KIP-405. Added a new version for `ListOffsets` protocol to receive local log start offset on the leader replica. This is...
We noticed this issue when appending value to `leader.replication.throttled.replicas`. The default value is empty string, so it produces `,0:0` rather than `0:0`. For another, parsing throttled replicas get failed when...
