set partitions to 1 and rename sbt modules

README.md

@@ -104,3 +104,11 @@ docker-compose up -d
 sbt it:test
 docker-compose down
 ```
+
+Run example application:
+
+```
+docker-compose up -d
+sbt sample/run
+docker-compose down
+```

build.sbt

@@ -77,7 +77,7 @@ val dependencies = Seq(
   "com.github.blemale" %% "scaffeine" % "4.0.1",
 )
 
-lazy val KaaSchemaRegistry = project
+lazy val kaa = project
   .configs(IntegrationTest)
   .settings(
     Defaults.itSettings,
@@ -88,15 +88,15 @@ lazy val KaaSchemaRegistry = project
     libraryDependencies ++= dependencies,
   )
 
-lazy val SampleApp = project
+lazy val sample = project
   .settings(
-    name := "SampleApp",
+    name := "sample",
     publish / skip := true,
   )
-  .dependsOn(KaaSchemaRegistry)
+  .dependsOn(kaa)
 
 lazy val root = (project in file("."))
-  .aggregate(KaaSchemaRegistry, SampleApp)
+  .aggregate(kaa, sample)
   .settings(
     publish / skip := true,
     crossScalaVersions := Nil,

KaaSchemaRegistry/src/main/scala/com/davideicardi/kaa/KaaSchemaRegistryAdmin.scala → kaa/src/main/scala/com/davideicardi/kaa/KaaSchemaRegistryAdmin.scala

@@ -16,7 +16,12 @@ class KaaSchemaRegistryAdmin(
   private val adminClient = AdminClient.create(props)
 
   def createTopic(): Unit = {
-    val newTopic = new NewTopic(topic, Optional.empty[java.lang.Integer](), Optional.empty[java.lang.Short]())
+    val NUMBER_OF_PARTITIONS = 1
+    val newTopic = new NewTopic(
+      topic,
+      Optional.of[java.lang.Integer](NUMBER_OF_PARTITIONS),
+      Optional.empty[java.lang.Short]()
+    )
     val newTopicsConfigs = Map (
       TopicConfig.CLEANUP_POLICY_CONFIG -> TopicConfig.CLEANUP_POLICY_COMPACT
     )