站长统计幸福宝宝官方使用中文域名的网站

Kafka Connect 能够为接收器连接器（从版本 0.11.0 开始）和源连接器（从版本 3.3.0 开始）提供一次性语义。请注意，对一次语义的支持高度依赖于您运行的连接器类型。即使您在集群中每个节点的配置中设置了所有正确的工作线程属性，如果连接器未设计为或无法利用 Kafka Connect 框架的功能，则可能无法实现精确一次。

一、Sink connectors

如果接收器连接器支持精确一次语义，要在 Connect 工作线程级别启用精确一次，您必须确保其使用者组配置为忽略中止事务中的记录。您可以通过将工作线程属性consumer.isolation.level设置为read_commissed来完成此操作。

或者如果运行支持它的Kafka Connect版本，则使用允许设置consumer.override.isolation.level属性的连接器在各个连接器配置中读取已提交。没有额外的 ACL 要求。