diff --git a/.scalafmt.conf b/.scalafmt.conf
new file mode 100644
index 0000000..834f2d2
--- /dev/null
+++ b/.scalafmt.conf
@@ -0,0 +1 @@
+version = 2.7.5
\ No newline at end of file
diff --git a/build.sbt b/build.sbt
new file mode 100644
index 0000000..15906bb
--- /dev/null
+++ b/build.sbt
@@ -0,0 +1,17 @@
+name := "flink-cdc-pipeline-connector-phaker"
+idePackagePrefix := Some("io.github.yuxiqian.phaker")
+version := "0.1.0-SNAPSHOT"
+scalaVersion := "2.12.19"
+
+val flinkVersion = "1.18.1"
+val flinkCdcVersion = "3.1.1"
+
+libraryDependencies ++= Seq(
+  "org.apache.flink" % "flink-runtime" % flinkVersion % "provided",
+  "org.apache.flink" % "flink-streaming-java" % flinkVersion % "provided",
+  "org.apache.flink" % "flink-cdc-common" % flinkCdcVersion,
+  "org.apache.flink" % "flink-cdc-runtime" % flinkCdcVersion,
+  "org.scalatest" %% "scalatest" % "3.2.19" % Test,
+  "org.apache.flink" % "flink-clients" % flinkVersion % Test,
+  "org.apache.flink" % "flink-streaming-java" % flinkVersion % Test
+)
diff --git a/phaker-pipeline-connector/src/main/resources/META-INF/services/org.apache.flink.cdc.common.factories.Factory b/phaker-pipeline-connector/src/main/resources/META-INF/services/org.apache.flink.cdc.common.factories.Factory
deleted file mode 100644
index 5fe9762..0000000
--- a/phaker-pipeline-connector/src/main/resources/META-INF/services/org.apache.flink.cdc.common.factories.Factory
+++ /dev/null
@@ -1 +0,0 @@
-io.github.yuxiqian.phaker.factory.PhakerDataFactory
diff --git a/project/build.properties b/project/build.properties
new file mode 100644
index 0000000..136f452
--- /dev/null
+++ b/project/build.properties
@@ -0,0 +1 @@
+sbt.version = 1.10.1
diff --git a/project/plugins.sbt b/project/plugins.sbt
new file mode 100644
index 0000000..eab8ad2
--- /dev/null
+++ b/project/plugins.sbt
@@ -0,0 +1 @@
+addSbtPlugin("org.jetbrains.scala" % "sbt-ide-settings" % "1.1.2")
diff --git a/phaker-pipeline-connector/src/main/scala/factory/PhakerDataFactory.scala b/src/main/scala/factory/PhakerDataFactory.scala
similarity index 100%
rename from phaker-pipeline-connector/src/main/scala/factory/PhakerDataFactory.scala
rename to src/main/scala/factory/PhakerDataFactory.scala
diff --git a/phaker-pipeline-connector/src/main/scala/source/PhakeDataGenerator.scala b/src/main/scala/source/PhakeDataGenerator.scala
similarity index 100%
rename from phaker-pipeline-connector/src/main/scala/source/PhakeDataGenerator.scala
rename to src/main/scala/source/PhakeDataGenerator.scala
diff --git a/phaker-pipeline-connector/src/main/scala/source/PhakerDataSource.scala b/src/main/scala/source/PhakerDataSource.scala
similarity index 100%
rename from phaker-pipeline-connector/src/main/scala/source/PhakerDataSource.scala
rename to src/main/scala/source/PhakerDataSource.scala
diff --git a/phaker-pipeline-connector/src/main/scala/source/PhakerDataSourceOptions.scala b/src/main/scala/source/PhakerDataSourceOptions.scala
similarity index 100%
rename from phaker-pipeline-connector/src/main/scala/source/PhakerDataSourceOptions.scala
rename to src/main/scala/source/PhakerDataSourceOptions.scala
diff --git a/phaker-pipeline-connector/src/main/scala/source/PhakerDatabase.scala b/src/main/scala/source/PhakerDatabase.scala
similarity index 100%
rename from phaker-pipeline-connector/src/main/scala/source/PhakerDatabase.scala
rename to src/main/scala/source/PhakerDatabase.scala
diff --git a/phaker-pipeline-connector/src/main/scala/source/PhakerMetadataAccessor.scala b/src/main/scala/source/PhakerMetadataAccessor.scala
similarity index 100%
rename from phaker-pipeline-connector/src/main/scala/source/PhakerMetadataAccessor.scala
rename to src/main/scala/source/PhakerMetadataAccessor.scala
diff --git a/phaker-pipeline-connector/src/main/scala/source/PhakerSourceFunction.scala b/src/main/scala/source/PhakerSourceFunction.scala
similarity index 100%
rename from phaker-pipeline-connector/src/main/scala/source/PhakerSourceFunction.scala
rename to src/main/scala/source/PhakerSourceFunction.scala
diff --git a/phaker-pipeline-connector/src/test/scala/PhakerTest.scala b/src/test/scala/PhakerTest.scala
similarity index 100%
rename from phaker-pipeline-connector/src/test/scala/PhakerTest.scala
rename to src/test/scala/PhakerTest.scala