CONFLUENT: Sync from apache/kafka trunk to confluentinc/kafka master (5 August 2022)
Version related conflicts: * Jenkinsfile * gradle.properties * streams/quickstart/java/pom.xml * streams/quickstart/java/src/main/resources/archetype-resources/pom.xml * streams/quickstart/pom.xml * tests/kafkatest/__init__.py * tests/kafkatest/version.py * commit 'add7cd85': (66 commits) KAFKA-14136 Generate ConfigRecord for brokers even if the value is unchanged (#12483) HOTFIX / KAFKA-14130: Reduce RackAwarenesssTest to unit Test (#12476) MINOR: Remove ARM/PowerPC builds from Jenkinsfile (#12380) KAFKA-14111 Fix sensitive dynamic broker configs in KRaft (#12455) KAFKA-13877: Fix flakiness in RackAwarenessIntegrationTest (#12468) KAFKA-14129: KRaft must check manual assignments for createTopics are contiguous (#12467) KAFKA-13546: Do not fail connector validation if default topic creation group is explicitly specified (#11615) KAFKA-14122: Fix flaky test DynamicBrokerReconfigurationTest#testKeyStoreAlter (#12452) MINOR; Use right enum value for broker registration change (#12236) MINOR; Synchronize access to snapshots' TreeMap (#12464) MINOR; Bump trunk to 3.4.0-SNAPSHOT (#12463) MINOR: Stop logging 404s at ERROR level in Connect KAFKA-14095: Improve handling of sync offset failures in MirrorMaker (#12432) Minor: enable index for emit final sliding window (#12461) MINOR: convert some more junit tests to support KRaft (#12456) KAFKA-14108: Ensure both JUnit 4 and JUnit 5 tests run (#12441) MINOR: Remove code of removed metric (#12453) MINOR: Update comment on verifyTaskGenerationAndOwnership method in DistributedHerder KAFKA-14012: Add warning to closeQuietly documentation about method references of null objects (#12321) MINOR: Fix static mock usage in ThreadMetricsTest (#12454) ...
显示
- build.gradle 31 个添加, 8 个删除build.gradle
- clients/src/main/java/org/apache/kafka/clients/admin/Admin.java 35 个添加, 2 个删除...s/src/main/java/org/apache/kafka/clients/admin/Admin.java
- clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java 8 个添加, 6 个删除...java/org/apache/kafka/clients/admin/KafkaAdminClient.java
- clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java 12 个添加, 2 个删除.../kafka/clients/admin/ListConsumerGroupOffsetsOptions.java
- clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult.java 49 个添加, 7 个删除...e/kafka/clients/admin/ListConsumerGroupOffsetsResult.java
- clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsSpec.java 79 个添加, 0 个删除...che/kafka/clients/admin/ListConsumerGroupOffsetsSpec.java
- clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java 2 个添加, 1 个删除.../apache/kafka/clients/admin/internals/AdminApiDriver.java
- clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java 2 个添加, 0 个删除...nts/admin/internals/AlterConsumerGroupOffsetsHandler.java
- clients/src/main/java/org/apache/kafka/clients/admin/internals/CoordinatorStrategy.java 4 个添加, 0 个删除...he/kafka/clients/admin/internals/CoordinatorStrategy.java
- clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java 74 个添加, 54 个删除...ents/admin/internals/ListConsumerGroupOffsetsHandler.java
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java 8 个添加, 7 个删除...kafka/clients/consumer/internals/AbstractCoordinator.java
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java 58 个添加, 15 个删除...kafka/clients/consumer/internals/ConsumerCoordinator.java
- clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java 21 个添加, 9 个删除...java/org/apache/kafka/clients/producer/KafkaProducer.java
- clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java 9 个添加, 4 个删除...e/kafka/clients/producer/internals/RecordAccumulator.java
- clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java 14 个添加, 0 个删除...va/org/apache/kafka/common/requests/JoinGroupRequest.java
- clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java 7 个添加, 3 个删除...org/apache/kafka/common/requests/OffsetFetchResponse.java
- clients/src/main/java/org/apache/kafka/common/security/auth/SaslExtensions.java 70 个添加, 13 个删除...org/apache/kafka/common/security/auth/SaslExtensions.java
- clients/src/main/java/org/apache/kafka/common/security/auth/SaslExtensionsCallback.java 2 个添加, 2 个删除...he/kafka/common/security/auth/SaslExtensionsCallback.java
- clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerClientInitialResponse.java 1 个添加, 1 个删除...uthbearer/internals/OAuthBearerClientInitialResponse.java
- clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/ValidatorAccessTokenValidator.java 0 个添加, 1 个删除...ty/oauthbearer/secured/ValidatorAccessTokenValidator.java
加载中
想要评论请 注册 或 登录