文件名称:debezium-server-iceberg
文件大小:58KB
文件格式:ZIP
更新时间:2024-04-23 08:53:18
Java
Debezium Iceberg消费者 该项目将冰山批处理使用者添加到有人可以使用此使用者并将数据库数据复制到iceberg表,而无需Spark,Kafka或Streaming平台。 iceberg消费者 将json事件附加到目标冰山表中,批大小由debezium确定。 如果启用了架构,则自动创建目标表debezium.format.value.schemas.enable=true 。 征服 debezium.sink.type = iceberg debezium.sink.iceberg.table-prefix = debeziumcdc_ debezium.sink.iceberg.table-namespace = default debezium.sink.iceberg.catalog-name = default debezium.sink.iceberg.fs.def
【文件预览】:
debezium-server-iceberg-master
----.github()
--------workflows()
----LICENSE(11KB)
----README.md(4KB)
----.run()
--------IcebergEventsChangeConsumerTest.run.xml(1KB)
--------clean,install.run.xml(1KB)
--------package.run.xml(1KB)
--------IcebergChangeConsumerTest.run.xml(1KB)
--------All in debezium-server-iceberg-sink.run.xml(828B)
----pom.xml(7KB)
----debezium-server-iceberg-sink()
--------src()
--------pom.xml(10KB)
----debezium-server-dist()
--------src()
--------README.md(167B)
--------pom.xml(6KB)
----.gitignore(2KB)