Kafka Connect MySQL JDBC Sink是否支持设置事务隔离级别?
解决Kafka Connect JDBC Sink设置MySQL事务隔离级别的问题
你可以通过以下方式设置非默认的事务隔离级别,不用局限于服务器全局配置:
通过MySQL JDBC驱动的URL参数指定
MySQL JDBC驱动支持在连接URL中通过transactionIsolation参数设置隔离级别,参数值对应JDBC标准的事务隔离常量,可选值包括:TRANSACTION_READ_UNCOMMITTEDTRANSACTION_READ_COMMITTEDTRANSACTION_REPEATABLE_READ(MySQL默认)TRANSACTION_SERIALIZABLE
示例连接URL:
jdbc:mysql://your-mysql-host:3306/your-db?transactionIsolation=TRANSACTION_READ_COMMITTEDKafka Connect JDBC Sink的行为说明
JDBC Sink本身不会主动设置或覆盖事务隔离级别,它完全依赖JDBC驱动建立连接时的配置。只要你在连接URL中指定了隔离级别,Connect任务就会使用这个级别进行数据库操作,不用担心被覆盖。全局配置的替代选项
服务器端全局配置确实能生效,但这种方式会影响所有连接到MySQL的应用。用URL参数的方式更灵活,只针对当前Kafka Connect任务生效,不会影响其他系统。
内容的提问来源于stack exchange,提问作者Donz
相关产品推荐
相关产品推荐

