我使用wso2-cep来处理来自kafka主题的事件。我想将其推广到多个kafka主题，这些主题以类似的格式存储日志，即每个主题的每个分区存储特定人的数据。
情景如下：；主题表示一个超级组，其中每个分区都是该组中的一个人。在每个分区中，都存在json格式的数据点{该人的银行交易信息（交易时间、借贷、金额）等}。
我希望能够以这样一种方式来分解数据，即在第一个（级别）执行计划之后，不同的人的数据被分解为单独的数据流，然后是第二个（级别）执行计划，该计划进一步将每个数据流分解为（时间戳，贷方/借方）流和（时间戳、金额）流。
实现这一点最简单的方法是编写一个程序，以编程方式为您写出执行计划（siddhisql文件）、事件流（json文件）、事件接收器和发布器（xml文件）。但是，随着主题数量的增加，这些文件的数量也随之增加。
是否有任何模板方法可以做到这一点（至少创建执行计划）？