【文件属性】:
文件名称:kafka-connect-mongodb:用于Kafka Connect的MongoDB接收器连接器
文件大小:24.06MB
文件格式:ZIP
更新时间:2021-05-02 15:40:59
kafka-connect kafka-connector mongodb-sink-connector Scala
kafka-连接-mongodb
您可以通过使用kafka9-connect-mongodb分支将此连接器用于Kafka9。
用于Kafka Connect的MongoDB接收器连接器提供了从Kafka主题或主题集到MongoDB集合或多个集合的简单,连续的链接。
连接器使用Kafka消息,重命名消息字段,选择特定的字段并将它们向上插入到MongoDB集合中。
连接器支持JSON和Avro格式的消息(带有或不带有模式)以及多个主题分区。
连接器配置:
范围
描述
例子
数据库主机
数据库的主机名
“本地主机”
db.port
数据库的端口号
“ 27017”
db.name
数据库名称
“ myDataBase”
db.collections
馆藏名称
“我的收藏
write.batch.enabled
当任务获取的记录多于write.batch.size时,使用批
【文件预览】:
kafka-connect-mongodb-master
----.gitignore(197B)
----README.md(9KB)
----build.sbt(780B)
----LICENSE(11KB)
----src()
--------test()
--------main()
----jars()
--------kafka 9()
--------kafka 10()
----project()
--------assembly.sbt(187B)
--------plugins.sbt(83B)
--------build.properties(21B)