repliqate:守护进程为仅追加工作负载提供 SQL -> Kafka 复制

复制 repliqate是一个守护进程，用于将行从 SQL 数据库复制到 Kafka 队列。 它“侦听”仅附加工作流中的 SQL 更改，并将新行发布为 Kafka 主题中的 JSON 序列化消息。 repliqate 可以使用任何类型的 SQL 数据库和作为输入。 某些数据库（如 SQLite）不提供用于跨进程边界实时侦听更改的接口。 repliqate 通过定期查询源数据库、在多个调用中维护状态/位置来“侦听”更改。 因此，repliqate 仅适用于仅追加写入模式。 手术 repliqate 将定期查询 SQL 数据库（指定为 URI）以获取新行。 它假设复制源表有一个单调递增的整数主键，用于在每次调用时跟踪最近复制的行。 因此，在每次调用时，repliqate 都会发布一批行（具有可配置的大小限制），这些行跟随上次调用（通过升序主键值）的行。 repliqate 本身是无状态的，