kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including...
Jira: https://issues.apache.org/jira/browse/KAFKA-17568 Move TestPurgatoryPerformance from Scala to Java, and transfer to use benchmark. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ]...
The PR removed the process fetch queue as we have moved to share fetch purgatory. As the fetches are passed to purgatory hence close of SharePartitionManager can't validate if all...
In previous implementation, we kept `partitionRacks` in `TopicMetadata`. However, it took too much memory, so we removed it in https://github.com/apache/kafka/pull/17233. We still need rack topology information to trigger rebalance, so...
When a message is too large to be sent (at org.apache.kafka.clients.producer.KafkaProducer#doSend), the RecordTooLargeException should carry the start of the record (for example, the first 1KB) so that the calling application...
If users subscribe to a topic with invalid name or without permission, they will get some exceptions. Network thread sends MetadataRequest and FindCoordinatorRequest in the background, so there will be...
JIRA: [KAFKA-17116](https://issues.apache.org/jira/browse/KAFKA-17116) This PR is aim to deliver [KIP-1082](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1082%3A+Require+Client-Generated+IDs+over+the+ConsumerGroupHeartbeat+RPC) and solves KAFKA-17716. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify...
Hi, @mjsax! I have removed the `transform` methods from the main and test classes. However, I have asked myself whether the approach I have used for `StandbyTaskEOSIntegrationTest` and `StreamThreadTest` is...
### About `minBytes` is a constraint that should be used to delay ShareFetch requests. Hence, I have added the support for minBytes in `DelayedShareFetch` class ### Testing The added code...
