Docs 菜单
Docs 主页
/
MongoDB Atlas
/

Atlas Stream Processing 更改日志

在此页面上

  • 2025 版本发布
  • 2024 年发布
  • executionTimeSecs 统计更改为 executionTimeMillis。要查看此统计信息,请调用 sp.processor.stats() 命令。

  • $emit 的缓冲持续时间更改为 Apache Kafka 汇,从 1000 毫秒改为 5 毫秒。

  • 支持与 Confluent 在 AWS 上进行 VPC 对等互联。

  • 支持使用 Atlas Administration API 来编辑流处理器。

  • 支持 AWS PrivateLink 与 Confluent 的集成。

  • 支持 Azure Private Link 与 EventHubs 的集成。

  • 当目标集群处于 REPAIRING 状态时,始终重试处理器。

  • 修复了恢复检查点后的 partitionIdleTimeout 问题。

  • 在详细统计信息中添加更多水印和窗口信息。

  • 确保发送到Apache Kafka的生产消息调用不会无限期挂起,即使生产者队列已满。

  • 支持使用 $convertBinary 数据转换为各种数据类型。这让您能够根据需要将 Kafka 标头转换为特定的数据类型。

  • 使用 Apache Kafka 作为源的流处理器在 sp.processor.stats() 中公开每个分区的水印。

  • 修复了用户无法通过 API 在某些区域创建Stream Processing 实例的错误。