Merge pull request #728 from apache/trunk
CONFLUENT: Sync from apache/kafka trunk to confluentinc/kafka master (13 Jun 2022) apache/trunk: (7 commits) KAFKA-13891: reset generation when syncgroup failed with REBALANCE_IN…(https://github.com/apache/kafka/pull/12140) KAFKA-10000: Exactly-once source tasks (https://github.com/apache/kafka/pull/11780) KAFKA-13436: Omitted BrokerTopicMetrics metrics in the documentation (https://github.com/apache/kafka/pull/11473) MINOR: Use Exit.addShutdownHook instead of directly adding hooks to R…(https://github.com/apache/kafka/pull/12283) KAFKA-13846: Adding overloaded metricOrElseCreate method (https://github.com/apache/kafka/pull/12121) KAFKA-13935 Fix static usages of IBP in KRaft mode (https://github.com/apache/kafka/pull/12250) HOTFIX: null check keys of ProducerRecord when computing sizeInBytes (https://github.com/apache/kafka/pull/12288) Conflicts: None
显示
- build.gradle 2 个添加, 1 个删除build.gradle
- clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java 5 个添加, 1 个删除...java/org/apache/kafka/clients/admin/KafkaAdminClient.java
- clients/src/main/java/org/apache/kafka/clients/admin/LogDirDescription.java 28 个添加, 0 个删除...ava/org/apache/kafka/clients/admin/LogDirDescription.java
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java 3 个添加, 0 个删除...kafka/clients/consumer/internals/AbstractCoordinator.java
- clients/src/main/java/org/apache/kafka/common/errors/IneligibleReplicaException.java 23 个添加, 0 个删除...pache/kafka/common/errors/IneligibleReplicaException.java
- clients/src/main/java/org/apache/kafka/common/errors/NewLeaderElectedException.java 23 个添加, 0 个删除...apache/kafka/common/errors/NewLeaderElectedException.java
- clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java 36 个添加, 4 个删除...rc/main/java/org/apache/kafka/common/metrics/Metrics.java
- clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java 8 个添加, 2 个删除...src/main/java/org/apache/kafka/common/metrics/Sensor.java
- clients/src/main/java/org/apache/kafka/common/protocol/Errors.java 5 个添加, 1 个删除...rc/main/java/org/apache/kafka/common/protocol/Errors.java
- clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionRequest.java 17 个添加, 4 个删除...g/apache/kafka/common/requests/AlterPartitionRequest.java
- clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java 1 个添加, 0 个删除...apache/kafka/common/requests/DescribeLogDirsResponse.java
- clients/src/main/resources/common/message/AlterPartitionRequest.json 7 个添加, 2 个删除.../main/resources/common/message/AlterPartitionRequest.json
- clients/src/main/resources/common/message/AlterPartitionResponse.json 8 个添加, 2 个删除...main/resources/common/message/AlterPartitionResponse.json
- clients/src/main/resources/common/message/DescribeLogDirsRequest.json 2 个添加, 1 个删除...main/resources/common/message/DescribeLogDirsRequest.json
- clients/src/main/resources/common/message/DescribeLogDirsResponse.json 9 个添加, 2 个删除...ain/resources/common/message/DescribeLogDirsResponse.json
- clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java 70 个添加, 0 个删除.../org/apache/kafka/clients/admin/KafkaAdminClientTest.java
- clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java 65 个添加, 0 个删除...a/clients/consumer/internals/AbstractCoordinatorTest.java
- clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java 6 个添加, 4 个删除...org/apache/kafka/common/requests/RequestResponseTest.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java 642 个添加, 0 个删除...pache/kafka/connect/runtime/AbstractWorkerSourceTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java 2 个添加, 6 个删除...java/org/apache/kafka/connect/runtime/ConnectMetrics.java
加载中
想要评论请 注册 或 登录