2.1.0 中的新功能
添加了对 SinkConnector的客户端字段级加密(CSFLE) 的支持。其中包括以下新的 MongoDB连接配置选项:
csfle.enabledcsfle.key.vault.namespacecsfle.local.master.keycsfle.schema.mapcsfle.bypass.query.analysis
添加了对接收器Connector的无状态字段解密的支持。其中包括以下新的后处理器配置选项:
field.value.transformerfield.value.transformer.fields
2.0.5 中的新功能
更新了Apache Kafka依赖项以解决安全漏洞。
2.0.3 中的新功能
更新了Connector行为,以明确将 TLS v1.3 作为首选安全协议,并在 v1.3 不可用时回退到 TLS v1.2。
getSecureSslContext()方法现在会返回配置有 TLS v1.3 的SSLContext。或 v1.2,,如果两者都不可用,则抛出NoSuchAlgorithmException。
2.0.2 中的新功能
当Connector无法恢复变更流时,将日志消息从
WARN级别更改为ERROR。此类错误现在已反映在故障指标中。
2.0.0 中的新功能
升级Apache Kafka依赖项以解决安全漏洞。
1.16.0 中的新功能
添加了
DeleteOneTombstoneBusinessKeyStrategy以变更流接收器Connector配置。
1.15.0 中的新功能
添加了
change.stream.show.expanded.events变更流源Connector配置。
1.14.1 中的新功能
修复了Apache Kafka 3.9 版本中引入的与Kafka SystemTime 类相关的问题。
1.14 中的新功能
添加了对使用
NullFieldValueRemover预构建帖子处理器删除输出中的所有空值字段的支持。 要学习;了解更多信息,请参阅预构建后处理器。
1.13.1 中的新功能
修复了任务重新启动时数据会再次进行自我复制的错误。要学习;了解有关此修复的更多信息,请参阅 KAFKA-428 JIRA 问题。
1.13 中的新功能
为 Source 连接器和 Sink 连接器添加了自定义身份验证提供者接口。 此功能使您能够在Connector中写入和使用自定义实施类。 要学习;了解更多信息,请参阅自定义身份验证提供程序指南。
修复如果配置包含密钥并使用
Provider框架,则在验证源连接器和接收器连接器的配置时出现的问题。要学习;了解有关此修复的更多信息,请参阅 KAFKA-414 JIRA 问题。
1.12 中的新功能
在
mongo.errors.tolerance配置设置中添加了对data配置值的支持。 使用mongo.errors.tolerance=data时,接收器Connector仅允许数据错误,对于任何其他错误都将失败。