benthos

{
  "aliases": [],
  "alternatives": [],
  "build_dependencies": [
    "go"
  ],
  "categories": [],
  "caveats": null,
  "conflicts_with": [],
  "dependencies": [],
  "deprecated": 0,
  "deprecation_reason": null,
  "desc": "Stream processor for mundane tasks written in Go",
  "disable_reason": null,
  "disabled": 0,
  "enrichment_fetched_at": "2026-06-20T23:35:50+00:00",
  "first_seen": "2026-06-20T23:34:18+00:00",
  "full_name": "benthos",
  "github_default_branch": "main",
  "github_last_commit_at": "2026-06-18T19:53:57Z",
  "github_readme_excerpt": "![Benthos](icon.png \"Benthos\")\n\n[![godoc for redpanda-data/benthos][godoc-badge]][godoc-url]\n[![Build Status][actions-badge]][actions-url]\n\n\u003e Note: if you are looking for the original benthos repo with connectors, it moved here: https://github.com/redpanda-data/connect\n\n\nBenthos is a framework for creating declarative stream processors where a pipeline of one or more sources, an arbitrary series of processing stages, and one or more sinks can be configured in a single config:\n\n```yaml\ninput:\n  gcp_pubsub:\n    project: foo\n    subscription: bar\n\npipeline:\n  processors:\n    - mapping: |\n        root.message = this\n        root.meta.link_count = this.links.length()\n        root.user.age = this.user.age.number()\n\noutput:\n  redis_streams:\n    url: tcp://TODO:6379\n    stream: baz\n    max_in_flight: 20\n```\n\n### Delivery Guarantees\n\nDelivery guarantees [can be a dodgy subject](https://youtu.be/QmpBOCvY8mY). Benthos processes and acknowledges messages using an in-process transaction model with no need for any disk persisted state, so when connecting to at-least-once sources and sinks it\u0027s able to guarantee at-least-once delivery even in the event of crashes, disk corruption, or other unexpected server faults.\n\nThis behaviour is the default and free of caveats, which also makes deploying and scaling Benthos much simpler.\n\n## Formatting and Linting\n\nBenthos uses [golangci-lint][golangci-lint] for formatting and linting.\n\n- `task fmt` to format the codebase,\n- `task lint` to lint the codebase.\n\n[godoc-badge]: https://pkg.go.dev/badge/github.com/redpanda-data/benthos/v4/public\n[godoc-url]: https://pkg.go.dev/github.com/redpanda-data/benthos/v4/public\n[actions-badge]: https://github.com/redpanda-data/benthos/actions/workflows/test.yml/badge.svg\n[actions-url]: https://github.com/redpanda-data/benthos/actions/workflows/test.yml\n\n[golangci-lint]: https://golangci-lint.run/\n",
  "github_repo": "redpanda-data/benthos",
  "github_stars": 538,
  "github_topics": [],
  "homepage": "https://github.com/redpanda-data/benthos",
  "homepage_og_description": null,
  "homepage_og_image": null,
  "homepage_title": null,
  "installs_30d": 60,
  "installs_365d": 1401,
  "installs_90d": 234,
  "keg_only": 0,
  "keg_only_reason": null,
  "last_seen": "2026-06-20T23:34:18+00:00",
  "license": "MIT",
  "llm_generated_at": null,
  "llm_model": null,
  "name": "benthos",
  "oldnames": [],
  "one_liner": null,
  "optional_dependencies": [],
  "rank_30d": 4310,
  "rank_365d": 3306,
  "rank_90d": 3925,
  "raw_hash": "fc0d0557b19c47a9",
  "recommended_dependencies": [],
  "revision": 0,
  "ruby_source_path": "Formula/b/benthos.rb",
  "tap": "homebrew/core",
  "test_dependencies": [],
  "uses_from_macos": [],
  "version_head": "HEAD",
  "version_stable": "4.75.0",
  "versioned_formulae": [],
  "why_use_this": null
}