Changelog
- Remove prefetch from pubsub source (#107)
- Ensure first window is always small (#106)
- Sources should report stream latency of stuck events (#105)
- Enable fairness on Kinesis Source's SynchronousQueue (#105)
- PubSub Source using Unary Pull (#101)
- Kinesis source improve management of shard ends (#102)
- Kinesis checkpointer should retry on dynamodb provisioned throughput exception (#103)
- Kafka Sink rewrite without fs2-kafka (#100)