filebeat修改源码，支持多个output类型

软件版本；filebeat-7.5
运行环境；linux
场景/上下文；我现在希望通过修改源码，起到能够同时发送报文到两种类型的output，例如es/kafka
 
通过初步学习，了解到应该修改publisher这个部分，但是filebeat-7.5的源码基本和网上的学习资料有差异了，看的比较累
特来求助各位大神，filebeat是在哪一步识别应该用哪种发送方式呢？