CONFLUENT: Sync from apache/kafka (8 October 2020)
* commit '2804257f': (67 commits) KAFKA-10562: Properly invoke new StateStoreContext init (#9388) MINOR: trivial cleanups, javadoc errors, omitted StateStore tests, etc. (#8130) KAFKA-10564: only process non-empty task directories when internally cleaning obsolete state stores (#9373) KAFKA-9274: fix incorrect default value for `task.timeout.ms` config (#9385) KAFKA-10362: When resuming Streams active task with EOS, the checkpoint file is deleted (#9247) KAFKA-10028: Implement write path for feature versioning system (KIP-584) (#9001) KAFKA-10402: Upgrade system tests to python3 (#9196) KAFKA-10186; Abort transaction with pending data with TransactionAbortedException (#9280) MINOR: Remove `TargetVoters` from `DescribeQuorum` (#9376) Revert "KAFKA-10469: Resolve logger levels hierarchically (#9266)" MINOR: Don't publish javadocs for raft module (#9336) KAFKA-9929: fix: add missing default implementations (#9321) KAFKA-10188: Prevent SinkTask::preCommit from being called after SinkTask::stop (#8910) KAFKA-10338; Support PEM format for SSL key and trust stores (KIP-651) (#9345) KAFKA-10527; Voters should not reinitialize as leader in same epoch (#9348) MINOR: Refactor unit tests around RocksDBConfigSetter (#9358) KAFKA-6733: Printing additional ConsumerRecord fields in DefaultMessageFormatter (#9099) MINOR: Annotate test BlockingConnectorTest as integration test (#9379) MINOR: Fix failing test due to KAFKA-10556 PR (#9372) KAFKA-10439: Connect's Values to parse BigInteger as Decimal with zero scale. (#9320) ...
显示
- bin/kafka-server-stop.sh 1 个添加, 1 个删除bin/kafka-server-stop.sh
- build.gradle 3 个添加, 4 个删除build.gradle
- checkstyle/import-control.xml 4 个添加, 1 个删除checkstyle/import-control.xml
- checkstyle/suppressions.xml 6 个添加, 3 个删除checkstyle/suppressions.xml
- clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java 2 个添加, 8 个删除...in/java/org/apache/kafka/clients/CommonClientConfigs.java
- clients/src/main/java/org/apache/kafka/clients/admin/Admin.java 68 个添加, 0 个删除...s/src/main/java/org/apache/kafka/clients/admin/Admin.java
- clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java 0 个添加, 6 个删除...ava/org/apache/kafka/clients/admin/AdminClientConfig.java
- clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesOptions.java 48 个添加, 0 个删除...g/apache/kafka/clients/admin/DescribeFeaturesOptions.java
- clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesResult.java 37 个添加, 0 个删除...rg/apache/kafka/clients/admin/DescribeFeaturesResult.java
- clients/src/main/java/org/apache/kafka/clients/admin/FeatureMetadata.java 111 个添加, 0 个删除.../java/org/apache/kafka/clients/admin/FeatureMetadata.java
- clients/src/main/java/org/apache/kafka/clients/admin/FeatureUpdate.java 78 个添加, 0 个删除...in/java/org/apache/kafka/clients/admin/FeatureUpdate.java
- clients/src/main/java/org/apache/kafka/clients/admin/FinalizedVersionRange.java 84 个添加, 0 个删除...org/apache/kafka/clients/admin/FinalizedVersionRange.java
- clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java 277 个添加, 49 个删除...java/org/apache/kafka/clients/admin/KafkaAdminClient.java
- clients/src/main/java/org/apache/kafka/clients/admin/SupportedVersionRange.java 82 个添加, 0 个删除...org/apache/kafka/clients/admin/SupportedVersionRange.java
- clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesOptions.java 29 个添加, 0 个删除...org/apache/kafka/clients/admin/UpdateFeaturesOptions.java
- clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesResult.java 48 个添加, 0 个删除.../org/apache/kafka/clients/admin/UpdateFeaturesResult.java
- clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java 10 个添加, 3 个删除...java/org/apache/kafka/clients/consumer/KafkaConsumer.java
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java 30 个添加, 24 个删除...kafka/clients/consumer/internals/AbstractCoordinator.java
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java 1 个添加, 1 个删除...kafka/clients/consumer/internals/ConsumerCoordinator.java
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java 107 个添加, 240 个删除...he/kafka/clients/consumer/internals/ConsumerProtocol.java
加载中
想要评论请 注册 或 登录