debezium-server-iceberg

时间:2024-04-23 08:53:18
【文件属性】:

文件名称: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)

网友评论