我想使用mongo kafka连接器在我们的微服务中实现发件箱模式，在我的发件箱（mongodb集合）中，我使用以下字段存储主题数据： kafka_topic , kafka_key , kafka_value , kafka_header_keys , kafka_header_values .
但是我应该如何配置mongo-kafka连接器，以便从 kafka_topic 字段以及其他发件箱字段的值和标题？我无法从其配置引用中找到执行此操作的设置。
我还考虑从mongo-kafka连接器存储库中获取一个fork，并用我的定制实现对其进行扩展。
如果你能帮助我，我将不胜感激。