我在 MySQL 数据库中有 3 个表，我正在使用 Debezium Kafka 连接器进行更改数据捕获。
TableA order_item: order_item_id, order_id, ...
TableB order: order_id, organization_id, ...
TableC organization: organization_id, type, ...
Downstream service requirement: order_item_id and type
我的下游服务需要 order_item_id 和类型。如您所见，我需要这 3 个表中的信息。但是，Debezium Kafka 连接器每次只会从单个表中捕获更改数据。
选项 1：我想知道如果这 3 个表在 MySQL 数据库中同时更新，Kafka Streams 中是否有任何方法可以加入这 3 个流。
选项 2：另一方面，我觉得我可以将 MySQL 数据库与我的 Kafka Streams 应用程序连接起来。当来自 TableA order_item 的消息进来时，我可以去 MySQL 数据库从 TableC 中找到相关类型。但是这种方式可能需要在每次消息进来时都在 MySQL 中进行查询，这可能会导致额外的内存使用。
感谢您的任何建议或建议。