Atlas Stream Processing 更改日志

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

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

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

确保生成消息到 Apache Kafka 的调用不会无限期挂起，即使在生成器队列已满的情况下也是如此。

支持摄取多主题Apache Kafka源。

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

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

支持无集合 $lookup 语法。

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

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

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

改进了已暂停集群错误。

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

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

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