# Extensions and Macros Preview

> For the complete documentation index, see [llms.txt](https://docs-extensions-and-macros.netlify.app/llms.txt). Component-specific: [preview-full.txt](https://docs-extensions-and-macros.netlify.app/preview-full.txt)

---
title: Extensions and Macros Preview
latest-operator-version: v26.2.2
latest-console-tag: v3.10.0
latest-connect-version: 4.106.0
latest-redpanda-tag: v26.2.2
# EOL = End-of-Life (support lifecycle status)
page-is-nearing-eol: "false"
page-is-past-eol: "true"
page-eol-date: April 1, 2025
docname: test
page-component-name: preview
page-version: master
page-component-version: master
page-component-title: Extensions and Macros Preview
page-relative-src-path: test.adoc
page-edit-url: https://github.com/redpanda-data/docs-extensions-and-macros/edit/HEAD/preview/extensions-and-macros/modules/ROOT/pages/test.adoc
description: This is a test description for structured data
page-topic-type: tutorial
page-git-created-date: "2023-07-06"
page-git-modified-date: "2026-08-12"
support-status: past end-of-life
---

<!-- Source: https://docs-extensions-and-macros.netlify.app/preview/test.md -->

This page is a preview of extensions and macros.

> 💡 **TIP**
>
> **Markdown output:** [View this page as Markdown](https://docs-extensions-and-macros.netlify.app/preview/test.md)
>
> Several macros on this page carry meaning in HTML attributes or CSS that a Markdown conversion cannot keep, so check both renderings when you change one. In particular, `enterprise` must appear as `(enterprise)` with its link intact, because the badge and tooltip it uses in HTML do not survive.
>
> The Markdown is generated by the `convert-to-markdown` extension, so this link only resolves in a full build, not in the Asciidoctor-only preview.

## [](#git-dates-extension-test)Git Dates Extension Test

The `add-git-dates` extension extracts accurate file creation and modification dates from Git history and makes them available to templates.

The extension automatically adds these dates by querying `git log`:

-   File created: 2023-07-06 (from first commit)

-   Last modified: 2025-08-08 (from most recent commit)


These dates are:

-   Exported to Markdown frontmatter (`git-created-date`, `git-modified-date`)

-   Used in structured data (JSON-LD) for `datePublished` and `dateModified`

-   Available to Handlebars templates as `page.attributes.git-created-date`


## [](#enterprise-macro)Enterprise macro

The `enterprise` macro marks a feature as an enterprise feature in prose. The feature name renders as a styled term (`enterprise-feature` class) with a tooltip explaining the license requirement, linking to the feature’s page or the licensing page. Targets are validated against the enterprise features registry (`enterprise-features.yml` in the `shared` component).

Both the badge and the tooltip are HTML-only: the badge comes from the CSS class and the explanation from a `title` attribute, so a Markdown conversion keeps neither. In the [Markdown output](https://docs-extensions-and-macros.netlify.app/preview/test.md) each term below reads `<name> (enterprise)` with its link preserved, which gives readers and agents an explicit licensing signal.

> 📝 **NOTE**
>
> This page sets `:enterprise-licensing-page: streaming:get-started:licensing/overview.adoc` because the default target (`get-started:licensing/overview.adoc`) is only resolvable from inside the docs component itself.

### [](#marking-forms)Marking forms

Default, no registry xref, linking to the licensing page: [Continuous Data Balancing](https://docs-extensions-and-macros.netlify.app/streaming/26.2/manage/cluster-maintenance/continuous-data-balancing/) (enterprise) in a sentence.

Registry-supplied feature link (the Tiered Storage entry carries an xref): [Tiered Storage](https://docs-extensions-and-macros.netlify.app/streaming/26.2/manage/tiered-storage/) (enterprise) in a sentence.

Per-use xref, overriding the registry (here, the Kubernetes variant of the feature page): [Tiered Storage](https://docs-extensions-and-macros.netlify.app/streaming/26.2/manage/kubernetes/tiered-storage/k-tiered-storage/) (enterprise) in a sentence.

Display text override (canonical name stays in the tooltip): [audit logging](https://docs-extensions-and-macros.netlify.app/streaming/26.2/manage/audit-logging/) (enterprise) in a sentence.

Tooltip override: [Iceberg Topics](https://docs-extensions-and-macros.netlify.app/streaming/26.2/manage/iceberg/about-iceberg-topics/) (enterprise) in a sentence.

Text and tooltip together: [audit logs](https://docs-extensions-and-macros.netlify.app/streaming/26.2/manage/audit-logging/) (enterprise) in a sentence.

### [](#registry-resolution)Registry resolution

Aliases and case-insensitive spellings canonicalize to the registry name, and the registry supplies the feature link.

From the alias `cloud_storage` (an internal core name, renders the canonical external name): [Tiered Storage](https://docs-extensions-and-macros.netlify.app/streaming/26.2/manage/tiered-storage/) (enterprise) in a sentence.

From a lowercase spelling: [Tiered Storage](https://docs-extensions-and-macros.netlify.app/streaming/26.2/manage/tiered-storage/) (enterprise) in a sentence.

An unknown feature name renders as written but logs a build warning with did-you-mean suggestions (set `enterprise-validate` to `error` to fail the build instead): [Warp Drive](https://docs-extensions-and-macros.netlify.app/streaming/26.2/get-started/licensing/overview/) (enterprise) in a sentence.

### [](#environment-specific-feature-links)Environment-specific feature links

Registry entries can carry `xref-kubernetes` and `xref-cloud` for features with separate Kubernetes, Linux, and Cloud documentation. Resolution follows the page’s `env-kubernetes`/`env-cloud` attributes, so it applies page-wide: see the [Kubernetes environment test page](https://docs-extensions-and-macros.netlify.app/preview/enterprise-kubernetes-test/), where the same `[Tiered Storage](https://docs-extensions-and-macros.netlify.app/streaming/26.2/manage/tiered-storage/) (enterprise)` call links to the Kubernetes feature page instead.

### [](#generated-feature-tables)Generated feature tables

The `enterprise_features` block macro renders the licensing feature table for one scope from the same registry.

Default titles and headings, with a block anchor that survives generation (see the crossref below):

| Feature | Description | Behavior Upon Expiration |
| --- | --- | --- |
| Audit Logging | Records detailed logs of cluster activities for compliance and monitoring. | Read access to the audit log topic is denied, but logging continues. |
| Continuous Data Balancing | Automatically balances partitions across a cluster to optimize resource use and performance. | Continuous balancing is disabled, reverting to node_add. |
| Iceberg Topics | Enables Iceberg integration for Redpanda topics. | Topics cannot be created or modified with the redpanda.iceberg.mode property. |
| Preview Beta Feature (beta) | Fixture for the beta release status. Available to readers, still changing. | The feature is disabled. |
| Tiered Storage | Enables data storage in cloud object storage for long-term retention and retrieval. | Topics cannot be created or modified to enable Tiered Storage features. |
| Topic Deletion Control (delete_topic_enable) | Prevents all users, including superusers, from deleting topics through the Kafka DeleteTopics API. | Topic deletion reverts to enabled (true). |

The operator scope demonstrates the `feature-suffix` field (a resource-name annotation) and the `beta: true` field, which renders the beta badge after the feature link. The badge is emitted as a passthrough rather than a `badge:` macro call, so it renders even though a playbook may not register that macro, and it degrades to the text `(beta)` in Markdown:

| Feature | Description | Restrictions Without Valid License |
| --- | --- | --- |
| Stretch Clusters (StretchCluster resource) (beta) | A single logical Redpanda cluster distributed across multiple Kubernetes clusters. | The multicluster operator requires a valid license to start. |

Custom `title` and `heading` overrides:

| Feature | Description | What stops working |
| --- | --- | --- |
| Enterprise connectors | Additional inputs, outputs, and processors available only to enterprise customers. | All enterprise connectors are blocked. |

The block anchor re-emitted above keeps crossrefs working: jump to [the Redpanda table](#demo-redpanda-features).

## [](#property-references-prop-macro)Property references (prop macro)

The `prop` macro marks a configuration property so the docs UI can decorate it with a hover tooltip. Targets are validated against the published property JSON (an attachment in the streaming component’s reference module). Marking is opt-in: plain backticked words never get tooltips, so ambiguous names like `admin` in Helm or feature contexts stay undecorated unless a writer marks them deliberately.

### [](#marking-only)Marking only

A cluster property: `cloud_storage_enabled` in a sentence.

A broker property: `fips_mode` in a sentence.

A dotted topic property: `redpanda.iceberg.mode` in a sentence.

An ambiguous name, marked deliberately (this is the opt-in fix in action, plain `admin` elsewhere stays untouched): `admin` in a sentence.

### [](#linked-page-discovered-dynamically)Linked, page discovered dynamically

The target page is discovered by indexing which reference page documents each property. This preview component publishes no property pages, so links resolve cross-component into the streaming component:

A cluster property: `[iceberg_enabled](https://docs-extensions-and-macros.netlify.app/preview/reference/properties/cluster-properties/#iceberg_enabled)` in a sentence.

A broker property: `[empty_seed_starts_cluster](https://docs-extensions-and-macros.netlify.app/preview/reference/properties/broker-properties/#empty_seed_starts_cluster)` in a sentence.

A topic property: `[retention.ms](https://docs-extensions-and-macros.netlify.app/preview/reference/properties/topic-properties/#retention-ms)` in a sentence.

### [](#overrides)Overrides

Display text: `write caching` in a sentence.

Display text and a link together: `[segment size](https://docs-extensions-and-macros.netlify.app/preview/reference/properties/cluster-properties/#log_segment_size)` in a sentence.

An explicit page override skips discovery entirely. The xref stays component-relative, so it only resolves in components that publish the page and can’t be demonstrated live from this preview component:

```asciidoc
prop:cloud_storage_cache_size[link=true,page=properties/object-storage-properties]
```

### [](#kubernetes-helm-paths)Kubernetes Helm paths

With `helm-path=auto`, the property renders as its Helm values path on pages with the `env-kubernetes` attribute, and as the plain name elsewhere. On this page (no `env-kubernetes`), it stays plain: `cloud_storage_enabled` in a sentence. See the same call on the [Kubernetes environment test page](https://docs-extensions-and-macros.netlify.app/preview/enterprise-kubernetes-test/).

### [](#validation)Validation

An unknown name renders as written but logs a build warning with did-you-mean suggestions (set `property-validate` to `error` to fail the build instead): `not_a_real_property` in a sentence.

## [](#terms)Terms

Terms must be defined in the `terms` module of the `shared` component (`shared/modules/terms/partials`).

Each partial file in this module is a term. Each file must include the following attributes:

-   `term-name`: The name of the term.

-   `hover-text`: A short definition of the term to be used as hover-over text.


If a page called `reference:glossary.adoc` exists in your component version, the contents of each term file gets merged into glossary during the build. Terms are merged in alphabetical order, according to the filename. The `aggregate-terms` extension is responsible for merging the content of each file into the glossary.

To reference a term in a doc topic, use the following syntax:

```asciidoc
glossterm:<term-name>[]
```

Replace `<term-name>` with the value of the `term-name` attribute in a term file.

To add custom link text for a term, which can be useful for displaying plurals or context-specific variations of the term without changing the term reference, use this syntax:

```asciidoc
glossterm:<term-name>[,<custom-link-text>]
```

Here, replace `<custom-link-text>` with your text that will appear as the link. For example:

[This link text is custom.](https://docs-extensions-and-macros.netlify.app/preview/reference/glossary/#test-term)

The `hover-text` attribute is read from the term file and used to add hover text to the term.

The rules for whether a link to the glossary entry is added to the term, depend on what content is available on the term page:

-   If you include only a title and the required `term-name` and `hover-text` attributes, a link to the glossary entry is added to the term.

    For example: [hover-only term](https://docs-extensions-and-macros.netlify.app/preview/reference/glossary/#hover-term)

-   If you include other Asciidoc content in the term page, such as headings, images, or paragraphs, a link to the glossary entry is added to the term so that users can read the full definition.

    For example: [test term](https://docs-extensions-and-macros.netlify.app/preview/reference/glossary/#test-term)

-   If you include an external URL in the `link` attribute, a link to that URL is added to the term.

    For example: [external term](https://redpanda.com)


### [](#local-development)Local development

For local development, you can test what your hover text will look like by adding the description to the macro like so:

```asciidoc
glossterm:term[This description is located in the Asciidoc source of this page]
```

This term is defined inline on this page. Inline terms do not include an internal link to the glossary page.

## [](#config_ref)config_ref

`[test](#reference:cluster-properties.adoc#test)`

`test`

## [](#helm_ref)helm_ref

For default values and documentation for configuration options, see the [`values.yaml`](https://artifacthub.io/packages/helm/redpanda-data/redpanda?modal=values&path=storage) file.

## [](#latest-versions)Latest versions

The `version fetcher` extension gets the latest version of Redpanda and Redpanda Console and assigns them to the following attributes:

-   `{full-version}`: 26.2.2

-   `{latest-redpanda-version}`: 26.2.2

-   `{redpanda-beta-version}`: {redpanda-beta-version}

-   `{redpanda-beta-tag}`: {redpanda-beta-tag}

-   `{latest-release-commit}`: fd30e45

-   `{latest-console-version}`: 3.10.0

-   `{console-beta-version}`: 3.0.0-beta.2

-   `{console-beta-tag}`: v3.0.0-beta.2

-   `{latest-operator-version}`: v26.2.2

-   `{latest-redpanda-helm-chart-version}`: 26.2.2


## [](#attachments)Attachments

By default, Antora does not replace attributes in attachment files. Download this test attachment to make sure that the correct elements were replaced:

[Download attachment](https://docs-extensions-and-macros.netlify.app/preview/_attachments/test.yaml)

The archive attachments extension is configured to archive all YAML files for the `preview` component. Test the extension by downloading this archive. It should contain the `test.yaml` file and include all replacements made by the replace-attributes-in-attachments extension.

[Download archive](https://docs-extensions-and-macros.netlify.app/test.tar.gz)

## [](#bloblang-samples)Bloblang samples

```json
{"hello.yaml":{"filename":"hello.yaml","title":"Hello world","input":"{\n  \"message\": \"hello world\"\n}\n","mapping":"root.message = this.message.uppercase()\n"}}
```

## [](#end-of-life-attributes)End-of-life attributes

This section provides a test for the compute-end-of-life extension as an example of what it generates.

The `preview` component is configured with a release date of 2024-04-01, and the extension is configured like so:

```yaml
  - require: './extensions/compute-end-of-life'
    data:
      eol_settings:
        - component: 'preview'
          supported_months: 12
          warning_weeks: 8
          eol_doc: https://support.redpanda.com/hc/en-us/articles/20617574366743-Redpanda-Supported-Versions
          upgrade_doc: ROOT:upgrade:index.adoc
```

The extension then generates the following data for the UI to use to build and display a notification banner for EoL versions:

-   `{page-is-nearing-eol}`: false

-   `{page-is-past-eol}`: true

-   `{page-eol-date}`: April 1, 2025

-   `{page-eol-doc}`: [https://support.redpanda.com/hc/en-us/articles/20617574366743-Redpanda-Supported-Versions](https://support.redpanda.com/hc/en-us/articles/20617574366743-Redpanda-Supported-Versions)

-   `{page-upgrade-doc}`: ROOT:upgrade:index.adoc


## [](#code-highlights)Code highlights

```js
function helloWorld() {
    console.log("Hello, World!") <sample>;
    console.log("This is a sample.");
    console.log("With multiple lines.");
    console.log("Highlighted using Prism.");
}
```

## [](#connector-table-with-all-data)Connector table with all data

Type:

All Types Selected ▼

 Processor Input  Output  Scanner  Metric  Cache  Tracer  Rate limit  Buffer

Support:

All Support Levels Selected ▼

 Certified Community

Available in Cloud:

All Options Selected ▼

 Yes No

Enterprise License:

All Options Selected ▼

 Yes No

| Name | Connector Type | Support Level | Enterprise Licensed | Available in Cloud |
| --- | --- | --- | --- | --- |
| a2a_message | Processor | Certified | Yes | Yes |
| amqp_0_9RabbitMQ AMQP | Input, Output | Certified | No | Yes |
| amqp_1RabbitMQ AMQP Apache Qpid | Input, Output | Community | No | No |
| arc | Output | Community | No | Yes |
| archiveZIP TAR GZIP | Processor | Certified | No | Yes |
| avro | Processor, Scanner | Community | No | Yes |
| awk | Processor | Community | No | No |
| aws_bedrock_chatAmazon AWS Bedrock Chat | Processor | Certified | No | Yes |
| aws_bedrock_embeddingsAmazon AWS Bedrock Embeddings | Processor | Certified | No | Yes |
| aws_cloudwatch | Metric | Community | No | No |
| aws_cloudwatch_logsAWS CloudWatch Logs Amazon CloudWatch Logs | Input | Community | No | Yes |
| aws_dynamodbAWS DynamoDB Amazon DynamoDB DynamoDB | Cache, Output | Community | No | Yes |
| aws_dynamodb_cdcAmazon DynamoDB CDC | Input | Certified | Yes | Yes |
| aws_dynamodb_partiqlAmazon AWS DynamoDB PartiQL | Processor | Certified | No | Yes |
| aws_kinesisAWS Kinesis Amazon Kinesis Kinesis | Input, Output | Certified | No | Yes |
| aws_kinesis_firehoseAWS Kinesis Firehose Amazon Kinesis Firehose Kinesis Firehose | Output | Certified | No | Yes |
| aws_lambdaAWS Lambda Amazon Lambda Lambda | Processor | Certified | No | Yes |
| aws_s3AWS S3 Amazon S3 S3 Simple Storage Service | Cache, Input, Output | Certified | No | Yes |
| aws_snsAWS SNS Amazon SNS SNS Simple Notification Service | Output | Community | No | Yes |
| aws_sqsAWS SQS Amazon SQS SQS Simple Queue Service | Input, Output | Certified | No | Yes |
| azure_blob_storageAzure Blob Storage Microsoft Azure Storage | Input, Output | Certified | No | Yes |
| azure_cosmosdbMicrosoft Azure Azure | Input, Output, Processor | Certified | No | Yes |
| azure_data_lake_gen2Microsoft Azure Azure | Output | Certified | No | Yes |
| azure_queue_storageAzure Queue Storage Microsoft Azure Queue | Input, Output | Certified | No | Yes |
| azure_table_storageAzure Table Storage Microsoft Azure Table | Input, Output | Certified | No | Yes |
| batched | Input | Certified | No | Yes |
| beanstalkd | Input, Output | Community | No | No |
| benchmark | Processor | Certified | No | Yes |
| bloblang | Processor | Certified | No | Yes |
| bounds_check | Processor | Certified | No | Yes |
| branch | Processor | Certified | No | Yes |
| broker | Input, Output | Certified | No | Yes |
| cache | Output, Processor | Certified | No | Yes |
| cached | Processor | Certified | No | Yes |
| cassandraApache Cassandra | Input, Output | Community | No | No |
| catch | Processor | Certified | No | Yes |
| chunker | Scanner | Certified | No | Yes |
| cockroachdb_changefeed | Input | Community | No | No |
| cohere_chat | Processor | Certified | No | Yes |
| cohere_embeddings | Processor | Certified | No | Yes |
| cohere_rerank | Processor | Certified | No | Yes |
| command | Processor | Certified | No | No |
| compress | Processor | Certified | No | Yes |
| couchbase | Cache, Output, Processor | Community | No | No |
| crash | Processor | Certified | No | No |
| csvComma-Separated Values | Input, Scanner | Certified | No | Yes |
| cyborgdb | Output | Community | No | Yes |
| cypher | Output | Community | No | No |
| decompress | Processor, Scanner | Certified | No | Yes |
| dedupe | Processor | Certified | No | Yes |
| discord | Input, Output | Community | No | No |
| doris_stream_load | Output | Community | No | No |
| drop | Output | Certified | No | Yes |
| drop_on | Output | Certified | No | Yes |
| dynamic | Input, Output | Community | No | No |
| elasticsearch_v8 | Output | Certified | No | Yes |
| elasticsearch_v9 | Output | Community | No | No |
| fallback | Output | Certified | No | Yes |
| ffiForeign Function Interface | Processor | Certified | No | No |
| file | Cache, Input, Output | Certified | No | No |
| for_each | Processor | Certified | No | Yes |
| gateway | Input | Certified | Yes | Yes |
| gcp_bigqueryGCP BigQuery Google BigQuery BigQuery | Output | Certified | No | Yes |
| gcp_bigquery_selectGCP BigQuery Google Cloud GCP | Input, Processor | Certified | No | Yes |
| gcp_bigquery_write_apiGCP BigQuery | Output | Certified | Yes | Yes |
| gcp_cloud_storageGCP Cloud Storage Google Cloud Storage GCS | Cache, Input, Output | Certified | No | Yes |
| gcp_cloudtraceGCP Cloud Trace | Tracer | Certified | No | Yes |
| gcp_pubsubGCP PubSub Google Cloud Pub/Sub GCP Pub/Sub Google Pub/Sub | Input, Output | Certified | No | Yes |
| gcp_spanner_cdcGoogle Cloud GCP | Input | Certified | Yes | Yes |
| gcp_vertex_ai_chatGCP Vertex AI Google Cloud GCP | Processor | Certified | No | Yes |
| gcp_vertex_ai_embeddingsGoogle Cloud GCP | Processor | Certified | No | Yes |
| generate | Input | Certified | No | Yes |
| git | Input | Certified | No | Yes |
| google_drive_download | Processor | Certified | Yes | Yes |
| google_drive_list_labels | Processor | Certified | Yes | Yes |
| google_drive_search | Processor | Certified | Yes | Yes |
| grok | Processor | Community | No | No |
| group_by | Processor | Certified | No | Yes |
| group_by_value | Processor | Certified | No | Yes |
| hdfs | Input, Output | Community | No | No |
| http | Processor | Certified | No | Yes |
| http_clientHTTP REST API REST | Input, Output | Certified | No | Yes |
| http_serverHTTP REST API REST Gateway | Input, Output | Certified | No | Yes |
| icebergApache Iceberg Apache Polaris AWS Glue Databricks Unity Catalog | Output | Certified | Yes | Yes |
| influxdb | Metric | Community | No | No |
| inproc | Input, Output | Certified | No | Yes |
| insert_part | Processor | Certified | No | Yes |
| jaeger | Tracer | Community | No | No |
| javascript | Processor | Certified | No | No |
| jiraAtlassian Jira | Input, Processor | Certified | No | Yes |
| jmespath | Processor | Certified | No | Yes |
| jq | Processor | Certified | No | Yes |
| json_api | Metric | Certified | No | No |
| json_array | Scanner | Community | No | Yes |
| json_documents | Scanner | Certified | No | Yes |
| json_schemaJSON Schema | Processor | Certified | No | Yes |
| kafkaApache Kafka | Input, Output | Certified | No | Yes |
| kafka_franzApache Kafka Kafka | Input, Output | Certified | No | Yes |
| lines | Scanner | Certified | No | Yes |
| local | Rate_limit | Certified | No | Yes |
| log | Processor | Certified | No | Yes |
| logger | Metric | Certified | No | No |
| lru | Cache | Community | No | Yes |
| mapping | Processor | Certified | No | Yes |
| memcached | Cache | Community | No | Yes |
| memory | Buffer, Cache | Certified | No | Yes |
| metric | Processor | Certified | No | Yes |
| microsoft_sql_server_cdc | Input | Certified | Yes | Yes |
| mongodbMongo | Cache, Input, Output, Processor | Certified | No | Yes |
| mongodb_cdcMongoDB CDC | Input | Certified | Yes | Yes |
| mqtt | Input, Output | Certified | No | Yes |
| msgpack | Processor | Community | No | No |
| multilevel | Cache | Certified | No | Yes |
| mutation | Processor | Certified | No | Yes |
| mysql_cdc | Input | Certified | Yes | Yes |
| nanomsg | Input, Output | Community | No | No |
| natsNATS.io | Input, Output | Certified | No | Yes |
| nats_jetstreamNATS JetStream NATS | Input, Output | Certified | No | Yes |
| nats_kvNATS KV | Cache, Input, Output, Processor | Certified | No | Yes |
| nats_request_replyNATS Request Reply | Processor | Certified | No | Yes |
| nats_streamNATS Stream NATS Streaming NATS | Input, Output | Community | No | No |
| none | Buffer, Metric, Tracer | Certified | No | Yes |
| noop | Cache, Processor | Certified | No | Yes |
| nsq | Input, Output | Community | No | No |
| ockam_kafka | Input, Output | Community | No | No |
| ollama_chat | Processor | Certified | No | No |
| ollama_embeddings | Processor | Certified | No | No |
| ollama_moderation | Processor | Certified | No | No |
| open_telemetry_collectorOpenTelemetry | Metric, Tracer | Certified | Yes | Yes |
| openai_chat_completion | Processor | Certified | No | Yes |
| openai_embeddings | Processor | Certified | No | Yes |
| openai_image_generation | Processor | Certified | No | Yes |
| openai_speech | Processor | Certified | No | Yes |
| openai_transcription | Processor | Certified | No | Yes |
| openai_translation | Processor | Certified | No | Yes |
| opensearch | Output | Certified | No | Yes |
| oracledb_cdcOracle CDC OracleDB CDC Oracle Database CDC | Input | Certified | Yes | Yes |
| otlp_grpcOpenTelemetry OTLP OTel gRPC | Input, Output | Certified | Yes | Yes |
| otlp_httpOpenTelemetry OTLP OTel | Input, Output | Certified | Yes | Yes |
| parallel | Processor | Certified | No | Yes |
| parquet | Input, Processor | Certified: inputCommunity: processor | No | No |
| parquet_decode | Processor | Certified | No | Yes |
| parquet_encode | Processor | Certified | No | Yes |
| parse_log | Processor | Community | No | Yes |
| pg_stream |  | Certified | Yes | Yes |
| pinecone | Output | Certified | No | Yes |
| postgres_cdc | Input | Certified | Yes | Yes |
| processors | Processor | Certified | No | Yes |
| prometheus | Metric | Certified | No | Yes |
| protobuf | Processor | Certified | No | No |
| pulsarApache Pulsar | Input, Output | Community | No | No |
| pusher | Output | Community | No | No |
| qdrant | Output, Processor | Certified | No | Yes |
| questdb | Output | Certified | No | Yes |
| rate_limit | Processor | Certified | No | Yes |
| re_match | Scanner | Certified | No | Yes |
| read_until | Input | Certified | No | Yes |
| redis | Cache, Processor, Rate_limit | Certified | No | Yes |
| redis_hashRedis Hash Redis | Output | Certified | No | Yes |
| redis_listRedis List Redis Lists Redis | Input, Output | Certified | No | Yes |
| redis_pubsubRedis PubSub Redis Pub/Sub Redis | Input, Output | Certified | No | Yes |
| redis_scanRedis | Input | Certified | No | Yes |
| redis_scriptRedis Script | Processor | Certified | No | Yes |
| redis_streamsRedis Streams Redis | Input, Output | Certified | No | Yes |
| redpanda | Cache, Input, Output, Tracer | Certified | No | Yes |
| redpanda_common | Input, Output | Certified | Yes | Yes |
| redpanda_data_transform | Processor | Certified | No | No |
| redpanda_migrator | Input, Output | Certified | No | Yes |
| reject | Output | Certified | No | Yes |
| reject_errored | Output | Certified | No | Yes |
| resource | Input, Output, Processor | Certified | No | Yes |
| retry | Output, Processor | Certified | No | Yes |
| ristretto | Cache | Community | No | Yes |
| salesforce | Input | Certified | Yes | Yes |
| salesforce_cdcSalesforce Salesforce CDC | Input | Certified | Yes | Yes |
| salesforce_graphqlSalesforce Salesforce GraphQL | Input | Certified | Yes | Yes |
| salesforce_sinkSalesforce Salesforce Sink | Output | Certified | Yes | Yes |
| schema_registry | Input, Output | Certified | No | Yes |
| schema_registry_decode | Processor | Certified | No | Yes |
| schema_registry_encode | Processor | Certified | No | Yes |
| select_parts | Processor | Certified | No | Yes |
| sentry_capture | Processor | Community | No | No |
| sequence | Input | Certified | No | Yes |
| sftp | Input, Output | Certified | No | Yes |
| skip_bom | Scanner | Certified | No | Yes |
| slack | Input | Certified | Yes | Yes |
| slack_postSlack Post | Output | Certified | Yes | Yes |
| slack_reactionSlack Reaction | Output | Certified | Yes | Yes |
| slack_threadSlack Thread | Processor | Certified | Yes | Yes |
| slack_usersSlack Users | Input | Certified | Yes | Yes |
| sleep | Processor | Certified | No | Yes |
| snowflake_putSnowflake | Output | Certified | Yes | Yes |
| snowflake_streamingSnowflake Streaming | Output | Certified | Yes | Yes |
| socket | Input, Output | Certified | No | No |
| socket_server | Input | Certified | No | No |
| spicedb_watch | Input | Community | No | Yes |
| split | Processor | Certified | No | Yes |
| splunk | Input | Certified | Yes | Yes |
| splunk_hecSplunk | Output | Certified | Yes | Yes |
| sql | Cache, Output, Processor | Certified: cacheCommunity: output, processor | No | Yes |
| sql_driver_clickhouseClickHouse |  | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | Yes |
| sql_driver_gocosmosAzure Cosmos DB |  | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | No |
| sql_driver_mssqlMicrosoft SQL Server |  | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | No |
| sql_driver_mysqlMYSQL |  | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | Yes |
| sql_driver_oracleOracle |  | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | Yes |
| sql_driver_postgresPostgreSQL |  | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | Yes |
| sql_driver_snowflakeSnowflake |  | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | No |
| sql_driver_sqliteSQLite |  | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | Yes |
| sql_driver_trinoTrino |  | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | No |
| sql_insertSQL PostgreSQL MySQL Microsoft SQL Server ClickHouse Trino | Output, Processor | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | Yes |
| sql_rawSQL PostgreSQL MySQL Microsoft SQL Server ClickHouse Trino | Input, Output, Processor | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | Yes |
| sql_selectSQL PostgreSQL MySQL Microsoft SQL Server ClickHouse Trino | Input, Processor | Certified: MYSQL, Oracle, PostgreSQL, SQLiteCommunity: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino | No | Yes |
| sqlite | Buffer | Community | No | No |
| statsd | Metric | Certified | No | No |
| stdin | Input | Certified | No | No |
| stdout | Output | Certified | No | No |
| string_split | Processor | Certified | No | Yes |
| subprocess | Input, Output, Processor | Community | No | No |
| switch | Output, Processor, Scanner | Certified | No | Yes |
| sync_response | Output, Processor | Certified | No | Yes |
| system_window | Buffer | Certified | No | Yes |
| tar | Scanner | Certified | No | Yes |
| text_chunker | Processor | Certified | No | Yes |
| tigerbeetle_cdc | Input | Certified | No | No |
| timeplus | Input, Output | Community | No | Yes |
| to_the_end | Scanner | Certified | No | Yes |
| try | Processor | Certified | No | Yes |
| try_catch | Processor | Community | No | Yes |
| ttlru | Cache | Community | No | Yes |
| twitter_search | Input | Community | No | No |
| unarchiveZIP TAR GZIP Archive | Processor | Certified | No | Yes |
| wasm | Processor | Community | No | No |
| websocket | Input, Output | Certified | No | No |
| while | Processor | Certified | No | Yes |
| workflow | Processor | Certified | No | Yes |
| xml | Processor | Community | No | Yes |
| zmq4 | Input, Output | Community | No | No |