KafkaConnect接收器设置kafka使用者隔离级别

问题描述

在标准/自定义kafkaconnect接收器中，我们如何指定它仅应使用来自kafka主题的read_comitted消息。我可以在此处看到配置，但看不到任何选项（除非这是默认行为）。谢谢。 https://docs.confluent.io/current/installation/configuration/connect/sink-connect-configs.html

解决方法

如果您想覆盖特定连接器的使用者属性（在您的情况下为isolation.level），请在工作程序配置中启用客户端覆盖，然后将consumer.override.*用于接收器连接器配置：

"consumer.override.isolation.level": "read_committed"

来源：Kafka Connect Worker Configuration Properties: Override the Worker Configuration

注意：在Kafka 2.3之前，您需要通过在worker config中添加以下行来将其设置为worker级别

consumer.isolation.level=read_committed

请参阅 how to set kafka connect auto.offset.reset with rest api