求指教：如何将logstash集成到SpringBoot中使用？

使用logstash可以 通过配置文件 完成将mysql数据同步到es中，我也会这样使用。
但是怎么集成到SpringBoot中呢？ 现在的需求是，想做一个通用的同步数据库到ES的功能， 用户输入数据库url 账户密码 表名，之后就能把这张表同步到ES中。
这个该如何实现呢？