Update README.md

README.md

@@ -24,7 +24,7 @@ For more information about KCL please visit the [official documentation](http://
 <dependency>
   <groupId>aserrallerios</groupId>
   <artifactId>kcl-akka-stream_2.11</artifactId>
-  <version>0.3</version>
+  <version>0.4</version>
   <type>pom</type>
 </dependency>
 ```
@@ -47,29 +47,31 @@ val workerSourceSettings = KinesisWorkerSourceSettings(
     bufferSize = 1000,
     terminateStreamGracePeriod = 1 minute,
     backpressureTimeout = 1 minute)
-  val builder: IRecordProcessorFactory => Worker = { recordProcessorFactory =>
-    new Worker.Builder()
-      .recordProcessorFactory(recordProcessorFactory)
-      .config(
-        new KinesisClientLibConfiguration(
-          "myApp",
-          "myStreamName",
-          DefaultAWSCredentialsProviderChain.getInstance(),
-          s"${
-            import scala.sys.process._
-            "hostname".!!.trim()
-          }:${java.util.UUID.randomUUID()}"
-        )
+
+val builder: IRecordProcessorFactory => Worker = { recordProcessorFactory =>
+  new Worker.Builder()
+    .recordProcessorFactory(recordProcessorFactory)
+    .config(
+      new KinesisClientLibConfiguration(
+        "myApp",
+        "myStreamName",
+        DefaultAWSCredentialsProviderChain.getInstance(),
+        s"${
+          import scala.sys.process._
+          "hostname".!!.trim()
+        }:${java.util.UUID.randomUUID()}"
       )
-      .build()
-  }
+    )
+    .build()
+}
 ```
 
 The Source also needs an `ExecutionContext` to run the Worker's thread and to commit/checkpoint records. Then the Source can be created as usual:
 
 ```scala
 implicit val _ =
   ExecutionContext.fromExecutorService(Executors.newFixedThreadPool(1000))
+
 KinesisWorkerSource(builder, workerSourceSettings).to(Sink.ignore)
 ```