@@ -31,7 +31,7 @@ For more information about KCL please visit the [official documentation](http://
31
31
32
32
``` scala
33
33
resolvers += " aserrallerios bintray" at " https://dl.bintray.com/content/aserrallerios/maven"
34
- libraryDependencies += " aserrallerios" %% " kcl-akka-stream" % " 0.3 "
34
+ libraryDependencies += " aserrallerios" %% " kcl-akka-stream" % " 0.4 "
35
35
```
36
36
37
37
## Usage
@@ -45,7 +45,8 @@ In order to use it, you need to provide a Worker builder and the Source settings
45
45
``` scala
46
46
val workerSourceSettings = KinesisWorkerSourceSettings (
47
47
bufferSize = 1000 ,
48
- terminateStreamGracePeriod = 1 minute)
48
+ terminateStreamGracePeriod = 1 minute,
49
+ backpressureTimeout = 1 minute)
49
50
val builder : IRecordProcessorFactory => Worker = { recordProcessorFactory =>
50
51
new Worker .Builder ()
51
52
.recordProcessorFactory(recordProcessorFactory)
@@ -89,6 +90,8 @@ KinesisWorkerSource(builder, workerSourceSettings).to(
89
90
KinesisWorker .checkpointRecordsSink(checkpointSettings))
90
91
```
91
92
93
+ Note that checkpointer Flow may not maintain input order of records of different shards.
94
+
92
95
## License
93
96
94
97
Copyright (c) 2018 Albert Serrallé
@@ -103,4 +106,4 @@ We build on a number of third-party software tools, with the following licenses:
103
106
104
107
Third-Party software | License
105
108
----------------------------|-----------------------
106
- amazon-kinesis-client | Amazon Software License
109
+ amazon-kinesis-client | Amazon Software License
0 commit comments