# lake-debezium-server
This project could be used to receive database CDC changes from debezium server and send it to [lake](https://github.com/datafuselabs/lake) table.It's in realtime and  started independently without the need for auxiliary streaming platforms such as Kafka, Flink and Spark. 

# debezium lake consumer
The detail introduction docs available in [docs page](./docs/docs.md)

# Install from source

- Requirements:
    - JDK 11
    - Maven
- Clone from repo: `git clone https://github.com/tidbcloud/lake-debezium-server.git`
- From the root of the project:
    - Build and package debezium server: `mvn -Passembly -Dmaven.test.skip package`
    - After building, unzip your server
      distribution: `unzip lake-debezium-server-dist/target/lake-debezium-server-dist*.zip -d lakeDist`
    - cd into unzipped folder: `cd lakeDist`
    - Create `application.properties` file and config it: `nano conf/application.properties`, you can check the example
      configuration
      in [application.properties.example](lake-debezium-server-sink/src/main/resources/conf/application.properties.example)
    - Run the server using provided script: `bash run.sh`
    - The debezium server with lake will be started

# Install from release
- Download zip file from [release](https://github.com/tidbcloud/lake-debezium-server/releases)
- Unzip it
- Create `application.properties` file and config it: `nano conf/application.properties`, you can check the example
    configuration
    in [application.properties.example](lake-debezium-server-sink/src/main/resources/conf/application.properties.example)
- Run the server using provided script: `bash run.sh`
- The debezium server with lake will be started

# Contributing

You are warmly welcome to hack on lake-debezium-server. We have prepared a guide [CONTRIBUTING.md](./CONTRIBUTING.md).