没有合适的资源?快使用搜索试试~ 我知道了~
kafka-connect-elasticsearch-source:Kafka Connect Elasticsearch源
共42个文件
java:28个
json:3个
license:2个
需积分: 32 2 下载量 72 浏览量
2021-05-07
03:22:18
上传
评论
收藏 74KB ZIP 举报
温馨提示
Kafka-connect-elasticsearch-source Kafka Connect Elasticsearch来源:从elastic-search获取数据并将其发送到kafka。 连接器仅使用严格的增量/时间字段(例如时间戳或增量ID)来获取新数据。 它支持动态模式和嵌套对象/数组。 要求: Elasticsearch 6.x和7.x Java> = 8 玛文 输出数据序列化格式: 连接器使用kafka-connect架构和结构,这些结构和结构与用户序列化方法无关(例如,它可能是Avro或json等)。 错误或新想法? 问题追踪器: : 随意打开一个话题来讨论新想法(或通过PR提出新的解决方案)。 安装: 使用以下命令编译项目: mvn clean package -DskipTests 您还可以使用以下命令编译和运行单元测试和集成测试(必须使用dock
资源推荐
资源详情
资源评论
收起资源包目录
kafka-connect-elasticsearch-source-master.zip (42个子文件)
kafka-connect-elasticsearch-source-master
pom.xml 4KB
.github
FUNDING.yml 53B
workflows
maven.yml 491B
assets
dariobalinzo.png 10KB
manifest.json 1KB
LICENSE 11KB
src
test
resources
com
github
dariobalinzo
logback.xml 321B
filter
document.json 455B
schema
complexDocument.json 7KB
java
com
github
dariobalinzo
filter
WhitelistFilterTest.java 3KB
JsonCastFilterTest.java 3KB
TestContainersContext.java 5KB
schema
AvroNameTest.java 1KB
SchemaConverterTest.java 13KB
elastic
ElasticRepositoryTest.java 2KB
ElasticSourceConnectorTest.java 2KB
task
MockOffsetFactory.java 2KB
ElasticSourceTaskTest.java 7KB
main
java
com
github
dariobalinzo
filter
JsonFilterVisitor.java 2KB
JsonCastFilter.java 2KB
JsonElementFilter.java 792B
WhitelistFilter.java 2KB
DocumentFilter.java 783B
schema
FieldNameConverter.java 807B
SchemaConverter.java 6KB
AvroName.java 1KB
NopNameConverter.java 955B
StructConverter.java 5KB
elastic
PageResult.java 1KB
ElasticRepository.java 5KB
ElasticConnection.java 4KB
ElasticConnectionBuilder.java 2KB
ElasticSourceConnector.java 5KB
ElasticSourceConnectorConfig.java 13KB
task
ElasticSourceTask.java 9KB
ElasticSourceTaskConfig.java 1KB
Version.java 742B
doc
LICENSE 11KB
README.md 5KB
.gitignore 51B
README.md 5KB
etc
quickstart-elasticsearch-source.properties 188B
共 42 条
- 1
资源评论
摔了个呆萌
- 粉丝: 28
- 资源: 4676
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功