stream-reactor

stream-reactor copied to clipboard

Add support for source connector to control the poll interval from s3

1

Added support for controlling the poll interval on the source connector. The default poll interval is 1 second. This update allows the interval to be changed using the parameter connect.s3.poll.interval.ms...

asafglassbox

## About this PR 📦 Updates * software.amazon.awssdk:s3 * software.amazon.awssdk:sts from `2.28.23` to `2.28.26` ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve conflicts as long as...

scala-steward

## About this PR 📦 Updates [org.scoverage:sbt-scoverage](https://github.com/scoverage/sbt-scoverage) from `2.2.1` to `2.2.2` 📜 [GitHub Release Notes](https://github.com/scoverage/sbt-scoverage/releases/tag/v2.2.2) - [Version Diff](https://github.com/scoverage/sbt-scoverage/compare/v2.2.1...v2.2.2) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...

scala-steward

## About this PR 📦 Updates * [org.scala-sbt:sbt](https://github.com/sbt/sbt) * [org.scala-sbt:scripted-plugin](https://github.com/sbt/sbt) from `1.10.2` to `1.10.3` 📜 [GitHub Release Notes](https://github.com/sbt/sbt/releases/tag/v1.10.3) - [Version Diff](https://github.com/sbt/sbt/compare/v1.10.2...v1.10.3) ## Usage ✅ **Please merge!** I'll automatically update this...

scala-steward

## About this PR 📦 Updates [org.elasticsearch:elasticsearch](https://github.com/elastic/elasticsearch) from `7.17.24` to `8.15.3` ⚠ 📜 [GitHub Release Notes](https://github.com/elastic/elasticsearch/releases/tag/v8.15.3) - [Version Diff](https://github.com/elastic/elasticsearch/compare/v7.17.24...v8.15.3) ## Usage ✅ **Please merge!** I'll automatically update this PR to...

scala-steward

## About this PR 📦 Updates * org.apache.hadoop:hadoop-common * [org.apache.hadoop:hadoop-mapreduce](https://hadoop.apache.org/) * org.apache.hadoop:hadoop-mapreduce-client * org.apache.hadoop:hadoop-mapreduce-client-core from `3.4.0` to `3.4.1` ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...

scala-steward

Update calcite-core, calcite-linq4j to 1.38.0

1

## About this PR 📦 Updates * [org.apache.calcite:calcite-core](https://github.com/apache/calcite) * [org.apache.calcite:calcite-linq4j](https://github.com/apache/calcite) from `1.34.0` to `1.38.0` ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve conflicts as long as...

scala-steward

S3 Source Connector throwing exception (Unable to instantiate request handler chain for client.)

2

I am using the s3 source connector to dump data from the s3 to kafka using **_kafka-connect-aws-s3-assembly-7.4.4.jar_**, Locally everything is working fine I am getting the data in the kafka,...

sunil-chormale-polestar

https://docs.lenses.io/connectors/kafka-connectors/sink/aws-s3 states that one should use WITH_FLUSH_COUNT, WITH_FLUSH_SIZE, WITH_FLUSH_INTERVAL, however when creating a connector based on this documentation kafka connect complains that these should be now properties.

nojetlag

Bumps [com.gradleup.shadow](https://github.com/GradleUp/shadow) from 8.3.2 to 8.3.3. Release notes Sourced from com.gradleup.shadow's releases. 8.3.3 Changed Disable Develocity integration by default. (#993) Commits cfa33fb Prepare version 8.3.3 88ca619 Update pull_request_template.md 1888cb6 Disable...

dependabot[bot]