我正在进行poc，目标如下：
答。使用kafka connect jdbc源连接器将oracledb表中的数据写入主题（例如：父级、子级）[[已实现]
b。将这些主题转换成Kafka流（父主题->父主题->子主题->子主题）[实现]
c。迭代父\u流并基于连接列从子\u流获取相应的子记录
d。转换每个父记录和相应的子记录，并创建一个pojo（父记录列表）。
e。使用上面的pojo创建json对象以供进一步处理。
目前，我一直在努力实现（c）点——所有的示例/演示似乎都在进行简单的转换（查找计数）。流连接/windows似乎不符合我的要求。
请提出实现上述目标的方法。还有，这是实现最终目标的正确途径吗？