kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
Deprecated Variable StreamsConfig#TOPOLOGY_OPTIMIZATION is removed ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status -...
*What* Added `ShareConsumerTest.java` for KafkaShareConsumers. We are using `KafkaClusterTestKit` for the integration tests.
related to https://issues.apache.org/jira/browse/KAFKA-12829 remove: org.apache.kafka.streams.Topology#addGlobalStore ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status -...
*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...
Per [KIP-289](https://cwiki.apache.org/confluence/display/KAFKA/KIP-289%3A+Improve+the+default+group+id+behavior+in+KafkaConsumer), the use of an empty value for group.id configuration was deprecated back in 2.2.0. In 3.7, the AsyncKafkaConsumer implementation will throw an error (see [KAFKA-14438](https://issues.apache.org/jira/browse/KAFKA-14438)). This task is...
With the new async consumer, the subscriptionState object is shared between the app thread and the background thread, but in principle all updates to the assignment should happen in the...
*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...
Add ReconfigurableQuorumIntegrationTest to test creating a cluster with KIP-853 enabled, to verify that the feature flag is set. Also test removing a voter. In order to make this test work,...
*More detailed description of your change, Only document *Summary of testing strategy (including rationale) ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [...
