This repository has been archived by the owner on Oct 11, 2023. It is now read-only.
- While streaming events from Azure IoT Hub, expose runtime information, to allow monitoring how many events are left to stream (see
MessageFromDevice.runtimeInfo
). - Change IoTHub public API to make it easier setting streaming options (see
SourceOptions
model) and to increase consistency across the board. - Allow to stream from the position stored in the checkpointing storage, without enabling checkpointing.
- Support Cassandra authentication when using Cassandra to store offsets checkpoints (@knordstrom).
- Fix: when building pull-requests, disable tests requiring Travis CI secrets.
- Fix: rename
created
messages property toreceived
. - Allow injecting Configuration, e.g. to override settings stored in application.conf.
- Reduce cost of logging instrumentation.
- Added some syntactic sure for the list of partitions to stream and the list of offsets to start from.
- Use SBT modules and add scripts to make it easier running the included samples.
- Upgrade Scala from 2.12.0 to 2.12.1
- Upgrade internal dependencies, e.g. Akka and Azure SDKs.