KafkaConnect接收器设置kafka使用者隔离级别
在标准/自定义kafkaconnect接收器中，我们如何指定它应该只使用来自kafka主题的read_comitted消息。我可以在这里看到配置，但看不到任何选项(除非这是默认行为)。谢了。https://docs . confluent . io/current/installation/configuration/connect/sink-connect-configs . html
共有1个答案
如果要覆盖特定连接器的使用者属性（在本例中为 isolation.level），请在工作线程配置中启用客户端替代，然后对接收器连接器配置使用 consumer.override.*：
“consumer.override.sisolation.level”：“read_committed”
来源：Kafka Connect Worker配置属性：覆盖Worker配置
注意：在 Kafka 2.3 之前，您需要通过在 worker 配置中添加以下行来在 worker 级别进行设置。
consumer.isolation.level=read_committed
请参阅如何使用 rest API 设置 kafka connect auto.offset.reset
-
问题内容： 我想将隔离级别设置为。如何使用gorm orm for postgres实现此目的。 示例代码： 问题答案： 我在这里有完全一样的问题： 和pg完全一样。
-
我想使用eclipse链接设置隔离级别，我尝试了以下两种方法： > java.sql.连接 Database aseLogin setTransationIsolation方法 如您所见，getTransactionSolation（）方法的返回值之间存在一些不一致。我的问题是，在这两种情况下真正设置了哪种事务隔离？我知道eclipse链接在默认情况下使用不同的连接进行读写操作，即Database
-
本文向大家介绍使用 Iisftp.vbs 设置Active Directory 用户隔离，包括了使用 Iisftp.vbs 设置Active Directory 用户隔离的使用技巧和注意事项，需要的朋友参考一下 应用到: Windows Server 2003, Windows Server 2003 R2, Windows Server 2003 with SP1 可使用命令行脚本 iisftp
-
我在使用时遇到了困难，无法从开头或其他任何显式偏移量读取它。 为同一主题的使用者运行命令行工具，我确实看到带有选项的消息，否则它将挂起 我使用的是kafka-python 0.9.5，而代理运行的是Kafka8.2。不确定确切的问题是什么。 按照dpkp的建议设置_group_id=none_以模拟控制台使用者的行为。
-
我正在写一个小拍卖app，这是非常重要的，我的出价是有把握的记录。毕竟，拍卖的最后几秒钟是买家的关键时刻，我不能冒险让他们同时出价和竞争。 当然，这就是事务隔离的目的。我可以将我的隔离级别设置为可序列化，然后我们就都设置好了。 但是其他的请求呢？如果用户正在查看配置文件或发送消息，则这些请求不需要任何接近那种事务隔离的地方。对于这些请求，“已提交读”隔离级别是完全可以接受的。 我正在将事务级别设置
-
我正在尝试使用Kafka-Python编写一个消费者，以确保精确的once语义。分区中的消息是使用事务感知生成器生成的。我从Kafka文档中了解到，我应该将指定为，这样它将只读取提交的消息。问题是，我在Python客户机的文档中没有看到关于如何指定的任何地方。关于如何让我的消费者只阅读提交的消息，有什么想法吗？ 预期结果：只需获取transation committed消息实际结果：使用者甚至读取