tamer:Kafka Connect连接器的独立替代品 源码

驯服者 Tamer是经过驯化的Kafka源连接器。 它使开发人员可以完全控制数据的摄取方式和保留的状态(在紧凑的Kafka主题中)。 例如,它允许JDBC源从过去的某个时间开始以最快的速度拉数据窗口(例如5分钟)。 在每次“拉动”时,开发人员都可以决定下一步要做什么(例如,是否应该增加/减小窗口?拉动速度是否应减慢?)。 Tamer当前支持两种可能的源类型:Doobie可以处理的任何SQL数据存储(例如Postgres,MySQL等)和“说” AWS S3协议的云存储。 开箱即用地提供了一些明智的默认设置,但是许多自定义也是可能的。 用法 将Tamer的模块之一添加为项目的依赖项: // check the current version on Maven Central (or use the badge above) libraryDependencies += "io.las