Skip to content

Commit af907f5

Browse files
Make it better
1 parent 3a36b61 commit af907f5

File tree

3 files changed

+11
-3
lines changed

3 files changed

+11
-3
lines changed

.gitignore

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
.venv/
2-
data/
32
.env
43
jars/
54
# *.log

README.md

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ Before runing this script, ensure you have the following installed.\
3232
* Delta Lake
3333
* Debezium, Debezium UI
3434

35-
## Setup environments
35+
## Start
3636

3737
1. **Clone the repository**
3838
```bash
@@ -71,7 +71,6 @@ Create `.env` file and paste your MINIO keys, SPARK_HOME in it.
7171
# Data
7272
- TABLE_NAME="products"
7373
- DATA_FILE='./data/products.csv'
74-
7574
```
7675

7776
4. **Services**
@@ -84,4 +83,14 @@ Create `.env` file and paste your MINIO keys, SPARK_HOME in it.
8483

8584
## How to use?
8685

86+
- **Step 1. Start Debezium Connection**
87+
```bash
88+
cd debezium
89+
bash run-cdc.sh register_connector conf/products-cdc-config.json
90+
```
8791

92+
You should see the connection is running like the image below in the port http://localhost:8085.
93+
94+
<p align = "center">
95+
<img src="assets/debezium-connect.png" alt="workflow" width = 80%>
96+
</p>

assets/debezium-connect.png

53.6 KB
Loading

0 commit comments

Comments
 (0)