Atlas Stream Processing 更改日志

支持 $currentDate 表达式，该表达式在 Atlas Stream Processing 每次对其求值时返回流处理实例的系统时间。

支持读取包含嵌入文件签名（magic bytes）的 JSON 文档。

修复了一个问题，该问题导致无法配置 hopSize 大于 interval 的跳跃窗口。

将 executionTimeSecs 统计信息更改为 executionTimeMillis。要查看此统计信息，请调用 sp.processor.stats() 命令。

将针对 Apache Kafka 接收器的 $emit 的缓冲持续时间从 1000 毫秒更改为 5 毫秒。

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

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

支持 AWS PrivateLink 与 Confluent 的集成。

支持附带 EventHub 的 Azure Private Link。

将“Apache Kafka 超时时间”从 10 秒增加到 30 秒。

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

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

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

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

支持摄取多主题Apache Kafka源。

将消费者群组的Apache Kafkaoffsets 更新为近乎实时。

支持Apache Kafka $emit 配置中的 和 设置。compression.typeacks

支持无集合 $lookup 语法。

标准化AtlasAtlas Stream Processing Stream Processing将ApacheApacheKafka stringKafka错误序列化为字符串的方式。

将 $emit 和 $merge 动态表达式限制增加到1000 。

使用窗口管道内唯一的 处理 $lookup。connectionName

改进了已暂停集群错误。

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

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

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