派生自
oss-mirrors / ICV / kafka
源项目有可见性限制。
Ismael Juma
编辑于
* 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) ...
名称 | 最后提交 | 最后更新 |
---|