diff --git a/apps/coordinator/build.gradle.kts b/apps/coordinator/build.gradle.kts
index 7e9fabac..cfaca258 100644
--- a/apps/coordinator/build.gradle.kts
+++ b/apps/coordinator/build.gradle.kts
@@ -1,6 +1,7 @@
 plugins {
     id("java")
     kotlin("jvm")
+    kotlin("plugin.spring") version "1.5.31"
     id("org.springframework.boot") version "2.5.5"
     id("io.spring.dependency-management") version "1.0.11.RELEASE"
 }
@@ -25,8 +26,8 @@ dependencies {
     /*Spring boot*/
     implementation("org.springframework.boot:spring-boot-starter-web")
     implementation("org.springframework.boot:spring-boot-starter:2.7.0")
-    implementation("org.springframework.kafka:spring-kafka:3.0.1")
-    // implementation("org.springframework.kafka:spring-kafka:2.8.5")
+    // implementation("org.springframework.kafka:spring-kafka:3.0.1")
+    implementation("org.springframework.kafka:spring-kafka:2.8.5")
     implementation("org.springframework.boot:spring-boot-starter-websocket:2.6.3")
 
     implementation("io.github.microutils:kotlin-logging-jvm:2.0.11")
diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt
index e226e893..9bb256c8 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt
@@ -26,8 +26,8 @@ fun getContext(): ApplicationContext? {
 }
 
 fun main(args: Array<String>) {
-    /*val dataSource = MySqlDataSource.fromDatabaseEnv();
-    Coroutines.default().launch {
+    // val dataSource = MySqlDataSource.fromDatabaseEnv();
+    /*Coroutines.default().launch {
         dataSource.createDatabase()
         dataSource.createTables(
             events