Skip to content
代码片段 群组 项目
派生自 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)
  ...
83f1575a
历史
名称 最后提交 最后更新