文件名称：kafka-connect
文件大小：28KB
文件格式：ZIP
更新时间：2024-06-13 12:40:22
C#
卡夫卡连接 该示例显示了如何将Marten与Docker和Kafka Connect一起使用。 在文档中查看有关Marten的更多信息： 。 本示例的目的是展示如何对以下流程建模： Marten是.NET框架，它允许将Posgres中的数据存储为Documents和Events。 文档和事件数据与文档表一起存储。 Marten表中的数据将通过具有Postgres CDC机制（接收器连接器）的Debezium框架进行移动。 2.1具有发件箱模式的事件表（ mt_events ）。 和看到更多。 2.2使用“常规”方法的文档表。 Debezium将数据移至Kafka Connect，然后移至Kafka。 然后将文档（ mt_doc_meetings ）通过Kafka Connect接收器连接器移动到ElasticSearch。 如何运行样品？ 运行以下docker命令：
【文件预览】：
kafka-connect-main
----.gitignore(4KB)
----connect()
--------DOCKERFILE(1KB)
--------scripts()
----docker-compose.watcher.yml(321B)
----test_utils()
--------connectors_setup_postman.json(4KB)
--------test.cmd(266B)
----postgres()
--------init.sql(1KB)
----docker-compose.yml(8KB)
----.github()
--------FUNDING.yml(698B)
----Marten.WebApi()
--------DOCKERFILE(382B)
--------Marten.WebApi()
--------Marten.WebApi.sln(1KB)
--------.editorconfig(6KB)
----README.md(4KB)
----.vscode()
--------launch.json(1KB)
--------tasks.json(341B)
----.gitattributes(84B)