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