在标准/自定义Kafka连接接收器中，我们如何指定它只使用来自Kafka主题的已读邮件。我可以在这里看到配置，但看不到任何选项（除非它是默认行为）。谢谢。https://docs.confluent.io/current/installation/configuration/connect/sink-connect-configs.html
rsaldnfx1#
如果要覆盖使用者属性( isolation.level 对于特定的连接器，在辅助配置中启用客户端覆盖，然后使用 consumer.override.* 对于接收器连接器配置： "consumer.override.isolation.level": "read_committed" 源：kafka connect worker配置属性：重写worker配置注意：在kafka 2.3之前，您需要通过在worker config中添加下面的行将其设置为worker级别
isolation.level
consumer.override.*
"consumer.override.isolation.level": "read_committed"
consumer.isolation.level=read_committed
请参见如何使用RESTAPI设置kafka connect auto.offset.reset
1条答案
按热度按时间rsaldnfx1#
如果要覆盖使用者属性(
isolation.level对于特定的连接器，在辅助配置中启用客户端覆盖，然后使用consumer.override.*对于接收器连接器配置："consumer.override.isolation.level": "read_committed"源：kafka connect worker配置属性：重写worker配置注意：在kafka 2.3之前，您需要通过在worker config中添加下面的行将其设置为worker级别
请参见如何使用RESTAPI设置kafka connect auto.offset.reset