文件名称：couchbasekafka:Couchbase Kafka 适配器
文件大小：18.71MB
文件格式：ZIP
更新时间：2024-07-14 00:10:49
Java
沙发床 Couchbase 代理将消息推送到 Kafka 跑步 mvn 清洁封装组件：单个 java -jar cbkafka-1.0-jar-with-dependencies.jar #config.properties 包含 TAP API 和适配器的设置 cb.cbserver= - Couchbase 服务器 cb.streamname=cookiestream - TAP 特定设置。 cb.startdate=1413500947028 cb.fulldump=true - 从一开始就完全转储数据。 如果 fulldump=true，则不使用 STREAM 名称和开始日期 //用于判断消息是否需要Transformation。 enableTransformation=true - 如果您想对数据进行预处理 //用于转换的自定义类。 CBMessageConver
【文件预览】：
couchbasekafka-master
----pom.xml(4KB)
----target()
--------test-classes()
--------cbkafka-1.0-SNAPSHOT.jar(18KB)
--------config.properties(524B)
--------classes()
--------maven-archiver()
--------cbkafka-1.0-SNAPSHOT-jar-with-dependencies.jar(16.38MB)
----.settings()
--------org.eclipse.m2e.core.prefs(86B)
--------org.eclipse.jdt.core.prefs(238B)
----src()
--------conf()
--------test()
--------main()
----.project(543B)
----.classpath(1KB)
----lib()
--------CouchbaseMock-0.8-SNAPSHOT.jar(4.23MB)
----README.md(1KB)
----LICENSE.txt(10KB)