Releases: yokawasa/kinesis-consumer
Releases · yokawasa/kinesis-consumer
v0.0.4
v0.0.3
- Add initialPositionInStream config param (default 1sec (1000L))
- Add maxRecrods config param (default 10sec (10000L))
- Add initialPositionInStream config param (LATEST or TRIM_HORIZON, default LATEST)
- Add idleTimeBetweenReadsInMillis config param (default 1 sec (1000L))