文件名称：kafka-connect-mongodb:用于Kafka Connect的MongoDB接收器连接器
文件大小：24.06MB
文件格式：ZIP
更新时间：2024-05-22 09:27:39
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)