文件名称：tamer:Kafka Connect连接器的独立替代品
文件大小：133KB
文件格式：ZIP
更新时间：2024-04-04 19:46:27
scala kafka avro schema-registry functional-programming
驯服者 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
【文件预览】：
tamer-master
----project()
--------build.properties(17B)
--------plugins.sbt(201B)
----.mergify.yml(266B)
----.github()
--------CODEOWNERS(22B)
--------workflows()
----core()
--------src()
----example()
--------src()
--------scripts()
----LICENSE(1KB)
----doobie()
--------local()
--------src()
----build.sbt(6KB)
----README.md(4KB)
----s3()
--------local()
--------src()
----fmt-all(28KB)
----.gitignore(148B)
----rest()
--------src()
----.scalafmt.conf(686B)