kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
This commit implements the changes for [KIP-1032](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1032%3A+Upgrade+to+Jakarta+and+JavaEE+10+in+Kafka+4.0). This updates Kafka to Jakarta specs, JavaEE 10 and Jetty 12. The changes here primarily effect Kafka Connect and MM2. **Todo/Notes:** 1. I...
Fix to avoid flakiness in verifiable producer system test. The test lists running processes and greps to find the VerifiableProducer one, but wasn't providing an specific pattern to grep (so...
This PR implements all the options for `--reset-offset`, (supports `--execute`, `--dry-run`, `--export`). Includes unit and integration tests. - --reset-offsets --input-topic String: topics --shift-by Long - --reset-offsets --input-topic String: topics --to-offset...
Support rack awareness in `UniformHomogeneousAssignmentBuilder`. The goal is balance > rack awareness > stickiness. ### Step 1: Check whether to use rack awareness strategy. Using rack awareness strategy only if...
MetadataRequest and MetadataResponse version 0 is still supported. Remove from README.md mentioning that they're not supported. It's unclear how such a mention was ever included in the file. It has...
The test testShareFetchRequestSuccessfulSharingBetweenMultipleConsumers was recently found to be flaky. Making the following small change that could potentially resolve the issue. Earlier, 1000 records were being produced and then 3 consecutive...
* Few logs in `PersisterStateManager` were noisy and not adding much value. * For the sake of reducing pollution, they have been moved to debug level. * Additional debug log...
[KAFKA-16717](https://issues.apache.org/jira/browse/KAFKA-16717) aims to finish the AlterShareGroupOffsets for ShareGroupCommand part.
`streams_broker_down_resilience_test` produce messages with `null` key to a topic with three partitions and expect each partition to be non-empty afterward. But I don't think this is a correct assumption, as...
Jira: https://issues.apache.org/jira/browse/KAFKA-17821 User can config different protocol in consumer config. We will print all config in log, but some configs has the default value and is unsupported for each protocol,...
