新增功能
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仅允许数据错误,对于任何其他错误都将失败。