JDBC汇合kafka连接器和每个模式的主题
我想知道有没有办法
>
每个架构而不是每个表创建主题。如果启用了每个模式的主题，那么是否可以在表的基础上支持模式演进（使用模式注册表）？
如果每个模式的主题是不可能的，那么有没有关于如何管理100个或数千个主题的指导方针？考虑到表数与主题数之间会有一对一的映射？
共有1个答案
-
我们已经成功地使用了MySQL - 使用jdbc独立连接器的kafka数据摄取，但现在在分布式模式下使用相同的连接器（作为kafka connect服务）时面临问题。 用于独立连接器的命令，工作正常 - 现在，我们已经停止了这一项，并以分布式模式启动了kafka connect服务，如下所示 2 个节点当前正在运行具有相同连接服务。 连接服务已启动并正在运行，但它不会加载 下定义的连接器。 应该对
-
我正在使用合流kafka connect jdbc源将mysql表中的记录推送到我的kafka主题，但似乎日期列被转换为纪元时间。 这是我的配置： kafka主题中的输出： 我也在类似于“select from_unixtime(updated _ on)from temp”的查询中尝试了from _ unixtime()，但是那不行。 有没有办法推到YYYY-MM-DD HH:MM:SS格式的K
-
分布式模式下Kafka Connect集群的偏移管理行为是什么，即运行多个连接器并监听同一组主题(或一个主题)？ 因此，在分布式模式下，Kafka Connect 会将偏移量信息存储在 Kafka 中，此偏移量将由集群中的工作线程读取和提交。如果我在该 Kafka Connect 集群中运行多个连接器侦听同一主题，会发生什么情况？分区的偏移量是否与所有连接器相同，或者每个连接器在分区上的偏移量是否
-
我正在尝试将MySQL与Kafka Connect连接，并且出现了许多错误。我正在共享我的connect-standalone.properties和mysql-jdbc-connector.properties，并显示错误。我的 Kafka 和 MySQL 在不同的集群中，我使用的是融合连接器，但不是在融合接口中。我下载了4.1.0 JDBC MySQL融合连接器。 MySQL-JDBC-con
-
我使用自己的自定义Sink插件运行Kafka Connect集群（本地有1个工人Docker Compose）。我想在连接器中使用几个主题：topicA、topicB、topicC，每个主题都有一个分区。 我的连接器启动时的配置子集如下： 使用此配置，我希望Kafka Connect为每个接收器任务分配一个主题，但遗憾的是，这不是我看到的。实践中发生的情况是，为分配了所有主题的每个任务调用Sink
-
我正在尝试将来自主题的数据（json数据）写入MySql数据库。我想我需要一个JDBC接收器连接器。 我如何配置连接器以将主题中的json数据映射到如何将数据插入数据库。 我能找到的文件只有这个。 “接收器连接器需要了解架构，因此您应该使用合适的转换器，例如架构注册表附带的Avro转换器，或启用了架构的JSON转换器。如果存在Kafka记录键，则可以是基元类型或连接结构，记录值必须是连接结构。从连