Add skeleton for Kafka sink

cosmincloud · Feb 28, 2019 · a3de1d5 · a3de1d5
1 parent 8b821b8
commit a3de1d5
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/checklister-eventsink-kafka/build.gradle.kts b/checklister-eventsink-kafka/build.gradle.kts
@@ -11,4 +11,5 @@ dependencies {
     // Kotlin
     implementation(kotlin("stdlib-jdk8"))
     implementation(project(":checklister-dto"))
+    implementation(project(":checklister-event"))
 }
diff --git a/...sink-kafka/src/main/kotlin/cloud/cosmin/checklister/lib/eventsink/kafka/KafkaEventSink.kt b/...sink-kafka/src/main/kotlin/cloud/cosmin/checklister/lib/eventsink/kafka/KafkaEventSink.kt
@@ -0,0 +1,10 @@
+package cloud.cosmin.checklister.lib.eventsink.kafka
+
+import cloud.cosmin.checklister.lib.event.Event
+import cloud.cosmin.checklister.lib.event.sink.EventSink
+
+class KafkaEventSink : EventSink {
+    override fun accept(event: Event) {
+        TODO("not implemented")
+    }
+}