Couchbase Java DCP客户端 此存储库包含Couchbase DCP(数据库更改协议)客户端的纯基于Java的实现。 重要说明:Couchbase并未直接正式支持java-dcp-client 。 它用作更高级别(受支持)库(例如我们的kafka或elasticsearch连接器)的基本构建块。 使用风险自负! 它支持: 低开销流 从上到下异步 流特定的vbuckets 手动开始/停止流 Noop确认和断开连接检测 流量控制 会话管理,可重启 重新平衡支持 导出当前会话状态以获得持久性(带有JSON的产品) 从特定的会话状态启动和重新启动(导入持久状态) 暂停并重新启动 流式传输到vbucket的特定时间点,然后停止 正确关闭/断开连接并进行清理 安装 我们发布发行版(包括到Maven Central的预发行版):