Kafka Reasearch Project for syncing MS-SQL Database with Kafka.
./make.shWorkflow
- use
make_local.shto create volume and download the necessray files for connector in the volume onlocalserver. - use
docker save xxxx > xxxx.tarto save the images as tar files - move the saved tar files to the
RD server - use
docker load -i xxxx.tarto build image on theRD server - use
cURLcommand to createsource connectoron db updateorinsertthe source table's row data to trigger thesource connectorto create the target topic- use
cURLcommand to createsink connectoron db - test the sync result.
| Step | Operation | Desp |
|---|---|---|
| 1 | Mount the neccessary file of JDBC Connector from volumes. | Details of dockerfile |
| 2 | Create containers by docker-compose up. |
Details of dockerfile |
| 3 | Create the target topic after building up kafka | |
| 4 | Create source and sink connector by http requests. | Details of connector API |
Guideline Table
| Use | File | Type |
|---|---|---|
| Introduction of Kafka | docs/KafkaIntroduction.md | Kafka |
| Common commands of Kafka | docs/KafkaShells.md | Kafka |
| Topic cleanup | docs/KafkaCleanup.md | Kafka |
| Kafka with CAP Theorem | doc/KafkaWithCAP.md | Kafka |
| Optimization of Kafka | docs/docs/KafkaOptimization.md | Kafka |
| Dockert setting of Kafka and Connectors | docs/KafkaDockerDoc.md | Kafka |
| Usecase of Debezium Connector API | docs/DebeziumConnectorAPI.md | Debezium |
| Setting of MSSQL's cdc | docs/SQLServerSetting.md | MS-SQL |
| Spike of MSSQL's cdc performance | docs/SQLCDCPerformance.md | MS-SQL |

