Atlas Stream Processing 更改日志

支持在 AWS 上使用 Confluent 进行 VPC对等互连等互连。

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

通过 Confluent 支持AWS PrivateLink 。

支持带有 EventHub 的Azure Private Link 。

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

当目标集群处于 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 实例的错误。