Meta tags:
description=Redpanda is a high-performance streaming data platform and Agentic Data Plane. Kafka API-compatible, it enables real-time data streaming, event-driven architectures, and AI agent governance and observability.;

Headings (most frequently used words):

you, to, on, what, data, this, page, let, us, everything, need, move, dataand, put, agents, work, it, are, here, for, build, agentic, flows, stream, and, process, components, highlight, hit, preview, attribute, title, do, think, of, know, more, contact, about, your, feedback, endpoint, example,

Text of the page (most frequently used words):
rpk (486), redpanda (124), cluster (110), cloud (62), connect (61), item (58), registry (55), #preview (54), list (54), the (51), and (48), api (47), configure (47), security (43), data (42), create (41), use (36), agent (35), html (34), delete (34), schema (33), with (32), storage (32), profile (32), state (31), config (31), mcp (30), return (29), topic (29), manage (28), get (27), context (27), iceberg (26), topics (26), oauth (26), set (25), const (22), console (22), for (21), reference (21), product (20), overview (19), sql (19), kubernetes (19), shadow (19), client (19), server (18), components (18), status (18), describe (18), query (17), deploy (16), transform (16), role (16), group (16), doc (15), hit (15), attribute (15), mode (15), kafka (15), generate (15), partitions (15), connector (15), index (14), migrate (14), user (14), admin (14), aws (14), algolia (13), monitor (13), update (13), properties (13), provider (13), com (12), add (12), byoc (12), catalog (12), compatibility (12), gcp (12), llm (12), version (11), plane (11), plugin (11), https (11), www (11), title (11), mongodb (11), linux (11), control (11), azure (11), show (10), streaming (10), objectid (10), your (10), patterns (10), install (10), remote (10), quotas (10), operator (10), access (10), auth (10), self (9), map (9), window (9), private (9), broker (9), agents (9), how (9), cdc (9), from (9), alter (9), brokers (9), debug (9), maintenance (9), catalogs (9), new (8), componenttitle (8), parameters (8), type (8), breadcrumbs (8), snippet (8), intro (8), description (8), run (8), started (8), build (8), source (8), helm (8), metrics (8), streams (8), bloblang (8), nats_kv (8), configuration (8), upgrade (8), acl (8), level (8), test (8), txn (8), producers (8), mount (8), enable (8), recovery (8), shadowing (8), a2a (8), docs (7), about (7), results (7), path (7), let (7), url (7), home (7), agentic (7), none (7), breadcrumb (7), highlight (7), start (7), cli (7), what (7), chart (7), resource (7), drop (7), log (7), http (7), introduction (7), failover (7), edit (7), license (7), transforms (7), authorization (7), connection (7), sink (7), dcr (7), env (7), link (6), facet (6), selected (6), time (6), titles (6), length (6), open (6), search (6), algoliabtn (6), text (6), event (6), queryid (6), positions (6), serverless (6), documentation (6), you (6), work (6), iam (6), redis (6), gcp_cloud_storage (6), aws_s3 (6), switch (6), sql_raw (6), azure_cosmosdb (6), init (6), subject (6), tune (6), print (6), decommission (6), globals (6), bundle (6), restore (6), connections (6), authentication (6), acls (6), messages (6), privatelink (6), tools (6), this (5), method (5), origin (5), integrate (5), platform (5), managed (5), exact (5), match (5), see (5), sources (5), hits (5), nestedhits (5), docindices (5), stoppropagation (5), clickedobjectidsaftersearch (5), eventname (5), __autocomplete_indexname (5), __autocomplete_queryid (5), objectids (5), activeitemid (5), href (5), pipelines (5), move (5), tiered (5), salesforce (5), snowflake (5), jira (5), message (5), google (5), amazon (5), roles (5), memory (5), secrets (5), check (5), uninstall (5), cancel (5), container (5), troubleshoot (5), specify (5), audit (5), service (5), quickstart (5), eol (5), secret (5), gateway (5), management (5), diff (5), apply (5), not (4), try (4), currentquery (4), all (4), fallback (4), filters (4), _tags (4), autocomplete (4), null (4), clickanalytics (4), true (4), matchingheading (4), tolowercase (4), custom (4), references (4), function (4), click (4), select (4), migrator (4), services (4), open_telemetry_collector (4), noop (4), aws_dynamodb (4), timeplus (4), sync_response (4), sql_insert (4), sftp (4), schema_registry (4), retry (4), redpanda_migrator (4), redpanda_common (4), redis_streams (4), redis_pubsub (4), redis_list (4), qdrant (4), otlp_grpc (4), otlp_http (4), nats_jetstream (4), nats (4), mqtt (4), kafka_franz (4), inproc (4), http_client (4), gcp_pubsub (4), cache (4), azure_table_storage (4), azure_queue_storage (4), azure_blob_storage (4), aws_sqs (4), aws_kinesis (4), amqp_0_9 (4), sql_select (4), processors (4), gcp_bigquery_select (4), decompress (4), avro (4), resources (4), produce (4), consume (4), help (4), stop (4), app (4), lint (4), mountable (4), disable (4), logdirs (4), v25 (4), node (4), read (4), replicas (4), based (4), gbac (4), rbac (4), throughput (4), requirements (4), system (4), production (4), works (4), dedicated (4), regions (4), join (4), revoke (4), billing (4), peering (4), centralized (4), egress (4), byovpc (4), iat (4), credential (4), task (4), ask (3), enrichment (3), hasendpoint (3), endpointline (3), curlexample (3), catch (3), current (3), view (3), getitems (3), header (3), right (3), render (3), libraries (3), concepts (3), getalgoliafacets (3), queries (3), params (3), phrase (3), false (3), getalgoliaresults (3), while (3), items (3), foreach (3), filter (3), _highlightresult (3), matchedindex (3), matchedtopleveltitle (3), clear (3), renderproduct (3), seen (3), supported_preview_types (3), includes (3), without (3), notes (3), action (3), document (3), btn (3), addeventlistener (3), slice (3), target (3), policy (3), v26 (3), deployment (3), connectors (3), code (3), database (3), token (3), guides (3), discord (3), ingest (3), postgresql (3), migrating (3), rest (3), authenticate (3), using (3), performance (3), methods (3), functions (3), logger (3), prometheus (3), local (3), file (3), couchbase (3), subprocess (3), http_server (3), dynamic (3), outputs (3), workflow (3), javascript (3), benchmark (3), csv (3), slack (3), inputs (3), telemetry (3), testing (3), processing (3), field (3), handling (3), lists (3), glossary (3), reset (3), rename (3), offset (3), grafana (3), import (3), info (3), features (3), pools (3), tls (3), enterprise (3), whole (3), runbook (3), availability (3), encryption (3), logging (3), types (3), sizing (3), transactions (3), addresses (3), labs (3), v24 (3), logout (3), login (3), tiers (3), timestamp (3), distinct (3), table (3), commits (3), policies (3), choose (3), debezium (3), mirrormaker2 (3), jdbc (3), model (3), transcript (3), endpoint (2), example (2), askaibutton (2), compose (2), that (2), viewalllink (2), strict (2), exacttoggle (2), side (2), our (2), values (2), tags (2), content (2), tagsbyfacet (2), tag (2), sourceid (2), checkbox (2), param (2), searchclient (2), indexname (2), test_redpanda (2), facetquery (2), maxfacethits (2), transformresponse (2), facethits (2), union (2), label (2), templates (2), every (2), term (2), matching (2), __algoliatoggleexactmatch (2), exactmatch (2), exactparams (2), hitsperpage (2), attributestosnippet (2), snippetellipsistext (2), tagfilters (2), order (2), are (2), nondocitems (2), unixtimestamp (2), infinity (2), nondocindex (2), full (2), has (2), stale (2), array (2), navigate (2), atag (2), setcontext (2), ctx (2), other (2), dropdown (2), can (2), autocompleteinstance (2), button (2), var (2), queryselector (2), detachedsearchbutton (2), key (2), know (2), _blank (2), rel (2), noopener (2), noreferrer (2), page (2), openchatwithquery (2), reliably (2), keep (2), stream (2), process (2), govern (2), plug (2), here (2), power (2), bot (2), retrieval (2), augmented (2), generation (2), rag (2), into (2), bigquery (2), write (2), joining (2), issues (2), routing (2), filtering (2), sampling (2), workflows (2), mysql (2), dynamodb (2), cookbooks (2), unified (2), via (2), aurora (2), web (2), credentials (2), synchronous (2), responses (2), tuning (2), pipeline (2), monitoring (2), arithmetic (2), walkthrough (2), gcp_cloudtrace (2), tracers (2), system_window (2), buffers (2), rate (2), limits (2), ttlru (2), ristretto (2), multilevel (2), memcached (2), lru (2), caches (2), zmq4 (2), websocket (2), splunk_hec (2), socket (2), snowflake_streaming (2), snowflake_put (2), slack_reaction (2), slack_post (2), salesforce_sink (2), reject_errored (2), reject (2), redis_hash (2), questdb (2), pulsar (2), pinecone (2), opensearch (2), ockam_kafka (2), nsq (2), nats_stream (2), nanomsg (2), hdfs (2), gcp_bigquery_write_api (2), gcp_bigquery (2), elasticsearch_v8 (2), drop_on (2), cyborgdb (2), cassandra (2), beanstalkd (2), azure_data_lake_gen2 (2), aws_sns (2), aws_kinesis_firehose (2), arc (2), amqp_1 (2), xml (2), unarchive (2), try_catch (2), text_chunker (2), string_split (2), split (2), sleep (2), slack_thread (2), select_parts (2), schema_registry_encode (2), schema_registry_decode (2), redis_script (2), rate_limit (2), protobuf (2), parse_log (2), parquet_encode (2), parquet_decode (2), parquet (2), parallel (2), openai_translation (2), openai_transcription (2), openai_speech (2), openai_image_generation (2), openai_embeddings (2), openai_chat_completion (2), ollama_moderation (2), ollama_embeddings (2), ollama_chat (2), nats_request_reply (2), mutation (2), metric (2), mapping (2), json_schema (2), jmespath (2), insert_part (2), group_by_value (2), group_by (2), google_drive_search (2), google_drive_list_labels (2), google_drive_download (2), gcp_vertex_ai_embeddings (2), gcp_vertex_ai_chat (2), for_each (2), dedupe (2), compress (2), command (2), cohere_rerank (2), cohere_embeddings (2), cohere_chat (2), cached (2), branch (2), bounds_check (2), aws_lambda (2), aws_dynamodb_partiql (2), aws_bedrock_embeddings (2), aws_bedrock_chat (2), archive (2), to_the_end (2), tar (2), skip_bom (2), re_match (2), lines (2), json_documents (2), json_array (2), chunker (2), scanners (2), splunk (2), spicedb_watch (2), slack_users (2), sequence (2), salesforce_graphql (2), salesforce_cdc (2), microsoft_sql_server_cdc (2), redis_scan (2), read_until (2), postgres_cdc (2), oracledb_cdc (2), mysql_cdc (2), mongodb_cdc (2), git (2), gcp_spanner_cdc (2), batched (2), aws_dynamodb_cdc (2), aws_cloudwatch_logs (2), unit (2), paths (2), interpolation (2), error (2), metadata (2), windowed (2), batching (2), versioning (2), licensing (2), quickstarts (2), logs (2), trim (2), prefix (2), unassign (2), assign (2), prompt (2), seek (2), shell (2), completion (2), dashboard (2), template (2), blobl (2), unmount (2), commands (2), rust (2), golang (2), sdks (2), release (2), object (2), errors (2), deserialization (2), rack (2), awareness (2), disaster (2), high (2), validation (2), contexts (2), lakehouse (2), databricks (2), unity (2), glue (2), fast (2), commission (2), listeners (2), partition (2), settings (2), sample (2), rolling (2), restart (2), balancing (2), external (2), networking (2), persistentvolumes (2), docker (2), readiness (2), checklist (2), nodes (2), paginate (2), follower (2), fetching (2), consumer (2), offsets (2), leader (2), pinning (2), idempotent (2), proxy (2), develop (2), partner (2), integrations (2), profiles (2), charts (2), older (2), versions (2), tables (2), bitwise (2), shift (2), left (2), operators (2), sum (2), min (2), max (2), count (2), bool_or (2), bool_and (2), avg (2), to_char (2), json (2), zone (2), numeric (2), support (2), pay (2), activity (2), hub (2), architecture (2), codex (2), claude (2), guardrail (2), guardrails (2), servers (2), complete (2), more (2), txt (2), answers, may, imprecise, always, verify, any, tiny, reduce, clicks, pure, required, touppercase, curl, assistant, respects, productparams, shows, products, 20data, 20plane, toggle, forces, typo, layout, footer, tips, root, define, used, actual, core, getsources, groupby, tagsplugin, fetch, populate, menu, raw, facets, known, happens, when, require, spelling, optional, word, note, deliberately, wrap, quotes, searchable, attributes, unordered, which, disables, proximity, quoted, returns, nothing, give, reliable, __algoliaexactmatch, typotolerance, removewordsifnoresults, optionalwords, maptoalgoliafilters, mixed, stay, place, non, sorted, compute, deep, best, sort, findindex, matchlevel, noresults, don, helper, deduped, badges, isarray, else, previewable, within, panel, otherwise, tab, getitemurl, onactive, expose, instance, globally, drive, its, capturing, across, renders, intentionally, namespaced, below, __algoliaautocompleteinstance, wire, sidebar, modal, clicking, hidden, detached, queryselectorall, keydown, enter, preventdefault, domcontentloaded, initalgolia, believe, should, close, esc, image, analytics, requires, children, checked, typeof, setisopen, cookie, preferences, trust, terms, privacy, 2026, inc, rights, reserved, transformations, infrastructure, clusters, between, systems, lean, top, observable, flows, monthly, budget, two, platforms, letting, act, safely, everything, need, put, specification, spanner, tigerbeetle, oracle, migration, files, lambda, delivery, semantics, playground, advanced, plugins, jaeger, json_api, influxdb, statsd, aws_cloudwatch, sqlite, stdout, pusher, elasticsearch_v9, doris_stream_load, cypher, wasm, sentry_capture, redpanda_data_transform, msgpack, grok, ffi, crash, awk, twitter_search, tigerbeetle_cdc, stdin, socket_server, cockroachdb_changefeed, cue, templating, allow, deny, prebuilt, binary, resume, pause, analyze, bootstrap, recommission, validate, iotune, download, purge, echo, dry, unsafe, recover, transfer, leadership, balancer, balance, health, force, export, internal, public, v1alpha2, definitions, specifications, resolve, inspect, bundles, diagnostics, strimzi, mirrormaker, package, repository, changes, deprecated, manually, rewrites, termination, optimize, raft, reconfiguration, fips, compliance, wise, forced, compaction, disk, space, continuous, resilience, pvcunbinder, scale, pod, groups, users, cert, manager, loadbalancer, nodeport, connectivity, expand, emptydir, hostpath, persistentvolume, volume, customize, guidelines, cases, manual, automated, development, options, hardware, software, worker, recommendations, kind, minikube, gke, eks, aks, examples, deserialize, editions, hide, v23, stdio, virtual, information, pg_user, pg_type, pg_statio_user_tables, pg_shadow, pg_settings, pg_roles, pg_proc, pg_namespace, pg_language, pg_index, pg_description, pg_depend, pg_database, pg_constraint, pg_class, pg_authid, pg_attribute, pg_attrdef, row_number, rank, percent_rank, ntile, nth_value, lead, last_value, lag, first_value, dense_rank, cume_dist, unix_seconds, unix_millis, unix_micros, to_timestamp, timestamp_trunc, timestamp_seconds, timestamp_millis, timestamp_micros, format_timestamp, extract, date_trunc, current_timestamp, upper, substring, strpos, starts_with, replace, position, lower, ends_with, concat, regexp_replace, regexp_match, posix, regular, expressions, regex, string, shobj_description, pg_typeof, pg_total_relation_size, pg_table_size, pg_table_is_visible, pg_size_pretty, pg_relation_is_publishable, pg_get_userbyid, pg_get_statisticsobjdef_columns, pg_get_indexdef, pg_get_expr, pg_get_constraintdef, pg_encoding_to_char, pg_backend_pid, obj_description, nullif, has_schema_privilege, generate_series, current_schema, current_database, col_description, coalesce, number, sqrt, sinh, sin, sign, round, random, least, greatest, floor, exp, cosh, ceil, cbrt, abs, math, json_extract_path_text, json_extract_path, json_array_length, json_array_extract, boolean, for_min, for_max, variance, var_samp, var_pop, stddev_samp, stddev_pop, stddev, regr_syy, regr_sxy, regr_sxx, regr_slope, regr_r2, regr_intercept, regr_count, regr_avgy, regr_avgx, covar_samp, covar_pop, corr, statistics, percentile_disc, percentile_cont, ordered, aggregate, row, aliases, interval, geometry, geography, date, bytea, bool, where, over, limit, having, outer, intersect, except, operations, clauses, execs, grant, copy, statements, schemas, comment, keywords, notifications, payment, safety, reliability, global, transit, cidr, ranges, network, design, ports, terraform, apis, programmable, push, upgrades, organization, heartbeat, checkpoint, gcs, single, converters, serialization, out, degraded, nested, fields, enabled, editor, dapper, npgsql, php, pdo, java, psycopg2, oltp, olap, real, sensor, a2a_message, contextual, variables, byovnet, tokens, mint, call, watch, send, card, gitops, bedrock, permissions, who, budgets, review, blocked, requests, did, observability, integration, pattern, stack, clients, github, delegated, inspector, register, zendesk, workday, sharepoint, servicenow, sentry, ramp, openapi, netsuite, metabase, ironclad, freshservice, bamboohr, tool, microsoft, teams, trigger, channels, draw, effective, prompts, understand, these, please, robot, before, submitting, submit, contact, feedback, think, beep, boop, familiar, syntax, learn, component, specific, llms, welcome,

Text of the page (random words):
bl rpk connect blobl server rpk connect create rpk connect dry run rpk connect echo rpk connect help rpk connect install rpk connect lint rpk connect list rpk connect mcp server rpk connect mcp server init rpk connect mcp server lint rpk connect plugin rpk connect plugin init rpk connect run rpk connect streams rpk connect template rpk connect template lint rpk connect test rpk connect uninstall rpk connect upgrade rpk container rpk container purge rpk container start rpk container status rpk container stop rpk debug rpk debug bundle rpk debug remote bundle rpk debug remote bundle cancel rpk debug remote bundle download rpk debug remote bundle start rpk debug remote bundle status rpk generate rpk generate app rpk generate grafana dashboard rpk generate license rpk generate prometheus config rpk generate shell completion rpk group rpk group delete rpk group describe rpk group list rpk group offset delete rpk group seek rpk help rpk iotune rpk plugin rpk plugin install rpk plugin list rpk plugin uninstall rpk profile rpk profile clear rpk profile create rpk profile current rpk profile delete rpk profile edit rpk profile edit globals rpk profile list rpk profile print rpk profile print globals rpk profile prompt rpk profile rename to rpk profile set rpk profile set globals rpk profile use rpk profile validate rpk redpanda rpk redpanda admin rpk redpanda admin brokers rpk redpanda admin brokers decommission rpk redpanda admin brokers decommission status rpk redpanda admin brokers list rpk redpanda admin brokers recommission rpk redpanda admin config rpk redpanda admin config log level rpk redpanda admin config log level set rpk redpanda admin config print rpk redpanda admin partitions rpk redpanda admin partitions list rpk redpanda check rpk redpanda config rpk redpanda config bootstrap rpk redpanda config init rpk redpanda config print rpk redpanda config set rpk redpanda mode rpk redpanda start rpk redpanda stop rpk redpanda tune rpk redpanda tune help rpk redpanda tune list rpk registry rpk registry compatibility level rpk registry compatibility level get rpk registry compatibility level set rpk registry context rpk registry context delete rpk registry context list rpk registry mode rpk registry mode get rpk registry mode reset rpk registry mode set rpk registry schema rpk registry schema check compatibility rpk registry schema create rpk registry schema delete rpk registry schema get rpk registry schema list rpk registry schema references rpk registry subject rpk registry subject delete rpk registry subject list rpk security rpk security acl rpk security acl create rpk security acl delete rpk security acl list rpk security role rpk security role assign rpk security role create rpk security role delete rpk security role describe rpk security role list rpk security role unassign rpk security user rpk security user create rpk security user delete rpk security user list rpk security user update rpk shadow rpk shadow config rpk shadow config generate rpk shadow create rpk shadow delete rpk shadow describe rpk shadow failover rpk shadow list rpk shadow status rpk shadow update rpk topic rpk topic add partitions rpk topic alter config rpk topic analyze rpk topic consume rpk topic create rpk topic delete rpk topic describe rpk topic describe storage rpk topic list rpk topic produce rpk topic trim prefix rpk transform rpk transform build rpk transform delete rpk transform deploy rpk transform init rpk transform list rpk transform logs rpk transform pause rpk transform resume rpk version glossary connect overview get started introduction to redpanda connect what s new quickstarts cli helm chart licensing versioning install and upgrade cli helm chart prebuilt binary build from source configuration resources allow and deny lists message batching windowed processing metadata error handling interpolation secrets field paths processing pipelines unit testing templating dynamic inputs and outputs using cue telemetry components catalog http inputs amqp_0_9 amqp_1 aws_cloudwatch_logs aws_dynamodb_cdc aws_kinesis aws_s3 aws_sqs azure_blob_storage azure_cosmosdb azure_queue_storage azure_table_storage batched beanstalkd broker cassandra cockroachdb_changefeed csv discord dynamic file gcp_bigquery_select gcp_cloud_storage gcp_pubsub gcp_spanner_cdc generate git hdfs http_client http_server inproc kafka kafka_franz mongodb mongodb_cdc mqtt mysql_cdc nanomsg nats nats_jetstream nats_kv nats_stream nsq ockam_kafka oracledb_cdc otlp_http otlp_grpc parquet postgres_cdc pulsar read_until redis_list redis_pubsub redis_scan redis_streams redpanda redpanda_common redpanda_migrator microsoft_sql_server_cdc resource salesforce salesforce_cdc salesforce_graphql schema_registry sequence sftp slack slack_users socket socket_server spicedb_watch splunk sql_raw sql_select stdin subprocess tigerbeetle_cdc timeplus twitter_search websocket zmq4 scanners avro chunker csv decompress json_array json_documents lines re_match skip_bom switch tar to_the_end processors archive avro awk aws_bedrock_chat aws_bedrock_embeddings aws_dynamodb_partiql aws_lambda azure_cosmosdb benchmark bloblang bounds_check branch cache cached cohere_chat cohere_embeddings cohere_rerank catch command compress couchbase crash decompress dedupe ffi for_each gcp_bigquery_select gcp_vertex_ai_chat gcp_vertex_ai_embeddings google_drive_download google_drive_list_labels google_drive_search grok group_by group_by_value http insert_part javascript jira jmespath jq json_schema log mapping metric mongodb msgpack mutation nats_kv nats_request_reply noop ollama_chat ollama_embeddings ollama_moderation openai_chat_completion openai_embeddings openai_image_generation openai_speech openai_transcription openai_translation parallel parquet parquet_decode parquet_encode parse_log processors protobuf qdrant rate_limit redpanda_data_transform redis redis_script resource retry schema_registry_decode schema_registry_encode select_parts sentry_capture slack_thread sleep split sql sql_insert sql_raw sql_select string_split subprocess switch sync_response text_chunker try try_catch unarchive wasm while workflow xml outputs amqp_0_9 amqp_1 arc aws_dynamodb aws_kinesis aws_kinesis_firehose aws_s3 aws_sns aws_sqs azure_blob_storage azure_cosmosdb azure_data_lake_gen2 azure_queue_storage azure_table_storage beanstalkd broker cache cassandra couchbase cyborgdb cypher discord doris_stream_load drop drop_on dynamic elasticsearch_v8 elasticsearch_v9 fallback file gcp_bigquery gcp_bigquery_write_api gcp_cloud_storage gcp_pubsub hdfs http_client http_server iceberg inproc kafka kafka_franz mongodb mqtt nanomsg nats nats_jetstream nats_kv nats_stream nsq ockam_kafka opensearch otlp_http otlp_grpc pinecone pulsar pusher qdrant questdb redis_hash redis_list redis_pubsub redis_streams redpanda redpanda_common redpanda_migrator reject reject_errored resource retry salesforce_sink schema_registry sftp slack_post slack_reaction snowflake_put snowflake_streaming socket splunk_hec sql sql_insert sql_raw stdout subprocess switch sync_response timeplus websocket zmq4 caches aws_dynamodb aws_s3 couchbase file gcp_cloud_storage lru memcached memory mongodb multilevel nats_kv noop redpanda redis ristretto sql ttlru rate limits local redis buffers memory sqlite none system_window metrics aws_cloudwatch logger open_telemetry_collector statsd influxdb none json_api prometheus tracers gcp_cloudtrace none jaeger open_telemetry_collector redpanda redpanda logger plugins bloblang walkthrough functions methods arithmetic advanced playground guides monitoring monitor pipeline status message delivery semantics performance tuning synchronous responses cloud credentials amazon web services authenticate to amazon aurora using iam roles google cloud platform serverless lambda streams mode streams via config files streams via rest api streams api migration migrate to the unified redpanda migrator migrating to version 4 migrating to version 3 migrating to version 2 cookbooks dynamodb cdc patterns oracle database cdc patterns mysql cdc patterns postgresql cdc patterns mongodb cdc patterns sql server cdc patterns tigerbeetle cdc patterns google cloud spanner cdc patterns enrichment workflows filtering and sampling message routing patterns work with jira issues joining streams stream data to bigquery with the storage write api ingest data into snowflake redpanda migrator retrieval augmented generation rag custom metrics create a discord bot reference helm chart specification redpanda documentation everything you need to move data and put agents to work on it guides concepts and references for the two platforms that power redpanda streaming your data reliably and letting ai agents act on it safely try how do i connect salesforce as an mcp source set a monthly token budget deploy redpanda on kubernetes what are you here for build agentic data flows build connect and govern ai agents on top of your data create agents without code plug in salesforce or your database and keep every action observable and in policy get started documentation stream and process data run redpanda clusters move data reliably between systems and keep storage lean with tiered storage and connectors data platform cloud streaming connect and sql with serverless or byoc deployment self managed deploy on your infrastructure streaming v26 1 redpanda broker and rpk cli connect data pipelines and transformations 2026 redpanda data inc all rights reserved privacy policy terms status trust cookie preferences for api endpoint results we show a tiny example to reduce clicks this is pure ui enrichment not required by algolia const hasendpoint preview preview method preview path let endpointline let curlexample if hasendpoint const method preview method get touppercase const path preview path endpointline method path let origin try origin new url preview url origin catch e no op curlexample curl x method origin origin path path integrate ai assistant with the current query const askaibutton currentquery html if typeof window openchatwithquery function window openchatwithquery currentquery true autocompleteinstance setisopen false ask ai about currentquery compose a view all results link that respects product version context const componenttitle home const productparams if componenttitle cloud return product 0 cloud product 1 connect if componenttitle streaming return product 0 streaming product 1 connect if componenttitle connect return product 0 connect if componenttitle data platform return product 0 cloud product 1 streaming product 2 connect if componenttitle self managed return product 0 streaming product 1 connect if componenttitle home return home shows all products if componenttitle agentic data plane return product 0 agentic 20data 20plane return const viewalllink currentquery html view all results exact match toggle forces a strict no typo no fallback query see getitems const exacttoggle html window __algoliatoggleexactmatch e target checked exact match layout header filters ai results list right side preview footer tips render html dropdown exacttoggle askaibutton children preview html preview breadcrumbs html preview breadcrumbs map breadcrumb html event stoppropagation click analytics requires clickanalytics true and a queryid docs https www algolia com doc api reference api parameters clickanalytics aa clickedobjectidsaftersearch eventname preview selected index state context preview __autocomplete_indexname queryid state context preview __autocomplete_queryid objectids state context preview objectid positions state activeitemid 1 positions start at 1 href breadcrumb u breadcrumb t components highlight hit preview attribute title preview intro components highlight hit preview attribute intro preview description components highlight hit preview attribute description preview api html preview api hasendpoint html endpoint endpointline example curlexample preview image html supported_preview_types includes preview type tolowercase html event stoppropagation aa clickedobjectidsaftersearch eventname preview selected index state context preview __autocomplete_indexname queryid state context preview __autocomplete_queryid objectids state context preview objectid positions state activeitemid 1 href preview url preview objectid html event stoppropagation aa clickedobjectidsaftersearch eventname preview selected index state context preview __autocomplete_indexname queryid state context preview __autocomplete_queryid objectids state context preview objectid positions state activeitemid 1 target _blank rel noopener noreferrer href preview url preview objectid preview titles preview titles length 0 html on this page preview titles slice 0 15 map title html supported_preview_types includes state context preview type tolowercase html event stoppropagation aa clickedobjectidsaftersearch eventname preview selected index state context preview __autocomplete_indexname queryid state context preview __autocomplete_queryid objectids state context preview objectid positions state activeitemid 1 href preview url preview objectid title h components highlight hit title attribute t html event stoppropagation aa clickedobjectidsaftersearch eventname preview selected index state context preview __autocomplete_indexname queryid state context preview __autocomplete_queryid objectids state context preview objectid positions state activeitemid 1 target _blank rel noopener noreferrer href preview url preview objectid title h components highlight hit title attribute t to select to navigate esc to close viewalllink root define our data sources filters facet values for the _tags facet used by the tags plugin docs actual content hits sources overview https www algolia com doc ui libraries autocomplete core concepts sources getsources query state const tagsbyfacet groupby state context tagsplugin tags tag tag facet return sourceid filters getitems fetch facet values for _tags to populate the checkbox menu getalgoliafacets https www algolia com doc ui libraries autocomplete api reference sources param getalgoliafacets return getalgoliafacets searchclient queries indexname test_redpanda facet _tags params facetquery https www algolia com doc api reference api parameters facetquery maxfacethits 50 https www algolia com doc api reference api parameters maxfacethits transformresponse facethits we return raw server facets union with known selected happens in render const server facethits 0 map h label h label facet _tags return server templates header return null item return null sourceid docs getitems when exact match is on require every term exact spelling and no optional word fallback note we deliberately do not wrap the query in quotes for a phrase match the index s searchable attributes use unordered which disables phrase proximity matching so a quoted phrase returns nothing strict params give reliable exact term matching see window __algoliatoggleexactmatch const exactmatch window __algoliaexactmatch const exact...