Ashley Jeffs
Ashley Jeffs
Log dump of the blocked pipeline: ``` INFO Main config updated, attempting to update pipeline. @service=benthos DEBU Waiting for pending acks to resolve before shutting down. @service=benthos label="" path=root.input DEBU...
Bloblang is pretty cool, and a lot of that coolness is that everything is an expression and mutations are methods you can chain: ``` map remove_naughty_man { root = match...
In cases where a refresh token exists for an OAuth 2.0 server but the client credentials are invalid we could potentially support using the existing refresh token. Taken from https://stackoverflow.com/questions/28685033/how-to-handle-refresh-tokens-in-golang-oauth2-client-lib...
For users that have plugins and parse their configs outside of the `service` package there was a regression when Benthos moved from yaml.v2 to yaml.v3, which manifests as certain components...
Let's try and annotate linting or compilation errors in the editor window.
In the context of an event processor a dead letter queue can mean a number of things. We can already support content based DLQs using transforms to route certain events...
TLDR; please do not open new issues in order to ask a question, either raise a new [discussion](https://github.com/redpanda-data/connect/discussions) or join one of our [community spaces](https://redpanda.com/slack). In an ideal world I...
The configuration of the `kafka_franz` input losely resembles the current `kafka` one in that it has a `checkpoint_limit` field as well as a `batching` field. The batching mechanism is operated...
I've done a broad refactor of the various kafka input/output components in order to: 1. Reduce the amount of duplicate field definitions and parsers 2. Reduce the amount of duplicate...