Recent Releases of https://github.com/awslabs/spark-sql-kinesis-connector
https://github.com/awslabs/spark-sql-kinesis-connector - v1.4.2
What's Changed
- Upgrade maven plugin and dependencies by @vrozov in https://github.com/awslabs/spark-sql-kinesis-connector/pull/47
- Add awssdk retries and retries-spi to shaded artifacts to avoid NoClassDefFoundError at runtime. by @vrozov in https://github.com/awslabs/spark-sql-kinesis-connector/pull/48
- Kinesis Spark connector fix for KDS returning non zero millisBehindLatest for an idle stream by @vrozov in https://github.com/awslabs/spark-sql-kinesis-connector/pull/49
- Scala
Published by vrozov about 1 year ago
https://github.com/awslabs/spark-sql-kinesis-connector - v1.4.1
fix bug in recordTtl casing (issue #35)
- Scala
Published by hwanghw over 1 year ago
https://github.com/awslabs/spark-sql-kinesis-connector - v1.4.0
- plumb through optional recordTtl param to KPL (issue #31)
- Allow defining the ExplicitHashKey for a Kinesis Sink (issue #23)
- Allow proxy configurations to be passed as option inputs for a sink (issue #21)
- Scala
Published by hwanghw over 1 year ago
https://github.com/awslabs/spark-sql-kinesis-connector - v1.3.0
- Scala
Published by hwanghw almost 2 years ago
https://github.com/awslabs/spark-sql-kinesis-connector - v1.2.1
fix for issue #13: error at assert(prevBatchId <= currBatchId)
- Scala
Published by hwanghw over 2 years ago
https://github.com/awslabs/spark-sql-kinesis-connector - v1.2.0
- Scala
Published by hwanghw over 2 years ago
https://github.com/awslabs/spark-sql-kinesis-connector - v1.1.0
- Scala
Published by hwanghw over 2 years ago
https://github.com/awslabs/spark-sql-kinesis-connector - v1.0.0
- Scala
Published by hwanghw over 2 years ago
https://github.com/awslabs/spark-sql-kinesis-connector - v1.0.0
- Scala
Published by hwanghw over 2 years ago