Produce records

Last updated Oct 12, 2026 You can write records to a K2 stream in two ways:

• Over HTTP, by sending a POST request to the stream's /produce endpoint.
• From a Worker, by calling send() on a Workers binding.

Each input must be enabled on the stream. Refer to Inputs.

Records and batches

A record has two fields:

Records are sent in batches. A batch must contain at least one record, and there is no limit on the number of records other than the maximum batch size. Batch writes are atomic, so either all records in the batch are recorded successfully or none are.

Timestamps are written by the server when the batch is received, and are not currently overridable by users.

For record, header, and batch size limits, refer to Limits.

Produce over HTTP

Send a POST request to https://<STREAM_ID>.k2.cloudflarestorage.com/produce. The request body is a JSON object with a records array. Record content must be standard base64.

curl "https://$STREAM_ID.k2.cloudflarestorage.com/produce" \
  --request POST \
  --header "Authorization: Bearer $CLOUDFLARE_API_TOKEN" \
  --header "Content-Type: application/json" \
  --data '{
    "records": [
      {
        "content": "eyJvcmRlcl9pZCI6MTAwMSwic3RhdHVzIjoiY3JlYXRlZCJ9",
        "headers": { "event-type": "order.created" }
      },
      {
        "content": "eyJvcmRlcl9pZCI6MTAwMiwic3RhdHVzIjoiY3JlYXRlZCJ9"
      }
    ]
  }'

{ "success": true }

The request must meet the following requirements:

• The Content-Type header must be application/json.
• To compress the request body, gzip it and set the Content-Encoding: gzip header. The size limit applies both before and after decompression.
• content must be standard base64 with correct padding. URL-safe base64 is not supported.
• The request body cannot contain fields other than records, and records cannot contain fields other than content and headers.
• If the HTTP input has authentication enabled, include an API token in the Authorization header.

Produce from a browser

To produce from a web page, add your site's origin to the stream's CORS configuration.

Do not include an API token in code that runs in a browser, because anyone who visits the page can read it. To produce from a browser, the stream's HTTP input must have authentication disabled. This makes the /produce endpoint public, so anyone who knows the stream ID can write records to the stream. Validate records in your consumers.

const encoder = new TextEncoder();

const records = [{ order_id: 1001, status: "created" }].map((event) => ({
    content: encoder.encode(JSON.stringify(event)).toBase64(),
    headers: { "event-type": "order.created" },
}));

const response = await fetch(
    "https://<STREAM_ID>.k2.cloudflarestorage.com/produce",
    {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify({ records }),
    },
);

const result = await response.json();
if (!result.success) {
    console.error(`Produce failed: ${result.error.message}`);
}

Uint8Array.prototype.toBase64() is available in recent browsers. For older browsers, use btoa() or a base64 library.

Produce from a Worker

A Workers binding lets a Worker produce to a stream without an API token. The binding handles authentication for you.

Configure the binding

Add a k2 binding to your Wrangler configuration file. Set stream to the ID of the stream to produce to:

{
  "$schema": "./node_modules/wrangler/config-schema.json",
  "name": "orders-producer",
  "main": "src/index.ts",
  "upload_source_maps": true,
  // Set this to today's date
  "compatibility_date": "2026-10-27",
  "k2": [
    {
      "binding": "ORDERS",
      "stream": "<STREAM_ID>"
    }
  ]
}

name = "orders-producer"
main = "src/index.ts"
upload_source_maps = true
# Set this to today's date
compatibility_date = "2026-10-27"

[[k2]]
binding = "ORDERS"
stream = "<STREAM_ID>"

To bind to more than one stream, add a [[k2]] entry for each stream.

When you deploy, Cloudflare checks that the stream exists in your account and that you have permission to use it. If the check fails, the deployment fails with one of the following errors:

Send records

Call send() on the binding with an array of records. Record content must be an ArrayBuffer or a Uint8Array. Every record in a batch must use the same type.

This example uses the Env type that wrangler types generates from your Wrangler configuration. Run npx wrangler types after you add the binding.

src/index.jsjs

export default {
    async fetch(request, env) {
        const event = { order_id: 1001, status: "created" };
        const encoder = new TextEncoder();

        const result = await env.ORDERS.send([
            {
                content: encoder.encode(JSON.stringify(event)),
                headers: { "event-type": "order.created" },
            },
        ]);

        if (!result.success) {
            console.error(`Produce failed: ${result.error.message}`);
            return new Response("Failed to record event", {
                status: result.error.retryable ? 503 : 500,
            });
        }

        return new Response("Event recorded");
    },
};

src/index.tsts

export default {
    async fetch(request, env): Promise<Response> {
        const event = { order_id: 1001, status: "created" };
        const encoder = new TextEncoder();

        const result = await env.ORDERS.send([
            {
                content: encoder.encode(JSON.stringify(event)),
                headers: { "event-type": "order.created" },
            },
        ]);

        if (!result.success) {
            console.error(`Produce failed: ${result.error.message}`);
            return new Response("Failed to record event", {
                status: result.error.retryable ? 503 : 500,
            });
        }

        return new Response("Event recorded");
    },
} satisfies ExportedHandler<Env>;

send() does not throw when K2 rejects a batch. Instead, it returns a result object. Check result.success after each call.

String content is not supported, including base64 strings. Encode text to bytes with TextEncoder before you send it.

Handle errors

When a batch fails, K2 returns an error object instead of { "success": true }. Over HTTP, the response also has a non-200 status code.

{
    "success": false,
    "error": {
        "code": 10211,
        "message": "K2 is temporarily unavailable",
        "retryable": true
    }
}

If retryable is true, K2 did not store the batch. Retry the same batch with exponential backoff.

If retryable is false, do not retry the batch without changing it. Some failures, such as 10212, have an unknown outcome: the batch may or may not have been stored. K2 does not deduplicate records, so retrying can store the batch twice. Design consumers to handle duplicate records.

<details>

<summary>

Produce error codes

</summary>

</details>

Next steps

• Consume records from the stream through a subscription.

Was this helpful?

YesNo

On this page

Docs

{"@context":"https://schema.org","@type":"TechArticle","@id":"https://developers.cloudflare.com/k2/features/produce/#page","headline":"Produce records","description":"Write records to a K2 stream over HTTP or from a Worker with a binding.","url":"https://developers.cloudflare.com/k2/features/produce/","inLanguage":"en","image":"https://developers.cloudflare.com/k2/features/produce/og.png?v=a597d5e720909ab0","dateModified":"2026-10-12","publisher":{"@type":"Organization","name":"Cloudflare","description":"One platform for your apps, agents, and workforce. Build, secure, and scale without managing infrastructure","url":"https://www.cloudflare.com/","sameAs":["https://github.com/cloudflare","https://www.linkedin.com/company/cloudflare","https://x.com/cloudflare"],"logo":{"@type":"ImageObject","url":"https://developers.cloudflare.com/logo.svg"},"address":{"@type":"PostalAddress","streetAddress":"101 Townsend St","addressLocality":"San Francisco","addressRegion":"CA","postalCode":"94107","addressCountry":"US"},"contactPoint":[{"@type":"ContactPoint","contactType":"Customer Support","url":"https://support.cloudflare.com/","availableLanguage":["English"]},{"@type":"ContactPoint","contactType":"Sales","url":"https://www.cloudflare.com/contact/","availableLanguage":["English"]}]},"isPartOf":{"@type":"WebSite","@id":"https://developers.cloudflare.com/#website","name":"Cloudflare Docs","url":"https://developers.cloudflare.com/"}}

description: Create, update, and delete K2 streams, and configure their inputs, authentication, CORS, and retention. title: Configuration image: https://developers.cloudflare.com/k2/configuration/og.png?v=b5ec4eb7360749ac

Skip to content

Documentation Index
Fetch the complete documentation index at: https://developers.cloudflare.com/k2/llms.txt
Use this file to discover all available pages before exploring further.