Tags: abarbibe/stream-reactor
Tags
LC-294 Allow a fixed interval retry on HTTP Sink (lensesio#220) * LC-294 Allow a fixed interval retry on HTTP Sink This PR adds new configuration entries for the HTTP sink to allow choosing fixed or exponential(default, and not change the existing deployments). It redefines the RetriesConfig to have one of the options and FixedRetryConfig offers the http4s implementation for the fixed interval. * Apply the format fixes * Unify the fixed and exponential retry config by a common trait. It reduces the code complexity and verbosity --------- Co-authored-by: stheppi <jenkins@lenses.io>
GCP PubSub Source (lensesio#209) The code was not wiring in the headers mapping. The change just ensures the SourceRecord created contains the headers as returned by the headers mapper Co-authored-by: stheppi <jenkins@lenses.io>
Merge pull request lensesio#186 from lensesio-dev/feat/log-offset-at-… …startup fix the unit test
Default sleep between polls (lensesio#182) * Update java-connectors/kafka-connect-azure-servicebus/src/main/java/io/lenses/streamreactor/connect/azure/servicebus/config/AzureServiceBusConfigConstants.java Co-authored-by: David Sloan <33483659+davidsloan@users.noreply.github.com> * separates the code that cleans up the resources used by the Service Bus subscription and the async client * Fix the usage of Option.of since the exception can be null. * Change the default sleep time window when empty records are to be returned to 250 for higher throughput --------- Co-authored-by: David Sloan <33483659+davidsloan@users.noreply.github.com> Co-authored-by: stheppi <jenkins@lenses.io>
PreviousNext