KafkaConnect sink设置kafka消费者隔离级别

Question

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

Answer 1

如果您想覆盖特定连接器的消费者属性（在您的情况下为 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

请看