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):
or tool bamboohr freshservice grafana ironclad jira kafka metabase netsuite openapi ramp salesforce sentry servicenow sharepoint slack sql workday zendesk create an mcp server register a self managed mcp server test an mcp server s tools with the inspector code mode set up authentication configure an oauth provider configure user delegated oauth set up github oauth provider and mcp server connect remote mcp clients integrate with your stack choose an integration pattern integrate with redpanda pipelines run claude code and codex monitor debug how observability works monitor agent activity see what your agent did troubleshoot agents control govern set up guardrails how guardrails work create a guardrail review blocked requests guardrail policy reference set up budgets manage access control who can do what roles and permissions reference routing llm settings how ai gateway works configure an llm provider set up aws bedrock as an llm provider connect your app to ai gateway use the agentic data plane cli manage resources with gitops reference install or update rpk rpk command reference rpk ai rpk ai agent rpk ai agent a2a rpk ai agent a2a card rpk ai agent a2a send rpk ai agent a2a task rpk ai agent a2a task cancel rpk ai agent a2a task get rpk ai agent a2a task watch rpk ai agent apply rpk ai agent create rpk ai agent credential rpk ai agent credential create rpk ai agent credential delete rpk ai agent credential list rpk ai agent delete rpk ai agent diff rpk ai agent get rpk ai agent list rpk ai agent start rpk ai agent stop rpk ai agent transcript rpk ai agent transcript get rpk ai agent transcript list rpk ai agent update rpk ai auth rpk ai auth login rpk ai auth logout rpk ai auth status rpk ai auth token rpk ai connection rpk ai connection list rpk ai connection revoke rpk ai env rpk ai env add rpk ai env delete rpk ai env list rpk ai env rename rpk ai env show rpk ai env use rpk ai install rpk ai llm rpk ai llm apply rpk ai llm check rpk ai llm create rpk ai llm delete rpk ai llm diff rpk ai llm get rpk ai llm list rpk ai llm update rpk ai mcp rpk ai mcp apply rpk ai mcp create rpk ai mcp delete rpk ai mcp diff rpk ai mcp get rpk ai mcp list rpk ai mcp tools rpk ai mcp tools call rpk ai mcp tools list rpk ai mcp types rpk ai mcp update rpk ai model rpk ai model get rpk ai model list rpk ai oauth client rpk ai oauth client apply rpk ai oauth client create rpk ai oauth client dcr rpk ai oauth client dcr get rpk ai oauth client dcr iat rpk ai oauth client dcr iat list rpk ai oauth client dcr iat mint rpk ai oauth client dcr iat revoke rpk ai oauth client dcr update rpk ai oauth client delete rpk ai oauth client diff rpk ai oauth client get rpk ai oauth client list rpk ai oauth client revoke tokens rpk ai oauth provider rpk ai oauth provider apply rpk ai oauth provider create rpk ai oauth provider delete rpk ai oauth provider diff rpk ai oauth provider get rpk ai oauth provider list rpk ai oauth provider update rpk ai run rpk ai run claude rpk ai run codex rpk ai uninstall rpk ai upgrade rpk ai version rpk cloud rpk cloud login rpk cloud logout rpk cloud cluster rpk cloud cluster select rpk profile rpk x glossary release notes data platform overview cloud overview get started what s new in redpanda cloud introduction to redpanda cloud introduction to redpanda how redpanda works byoc architecture deploy serverless byoc aws create a byoc cluster on aws create a byovpc cluster on aws azure create a byoc cluster on azure create a byovnet cluster on azure gcp create a byoc cluster on gcp create a byovpc cluster on gcp enable redpanda connect on a byovpc cluster on gcp enable secrets management on a byovpc cluster on gcp create remote read replicas dedicated redpanda connect quickstart configuration message batching windowed processing metadata error handling contextual variables interpolation field paths manage secrets process pipelines manage pipeline resources monitor data pipelines unit testing components catalog inputs amqp_0_9 aws_cloudwatch_logs aws_dynamodb_cdc aws_kinesis aws_s3 aws_sqs azure_blob_storage azure_cosmosdb azure_queue_storage azure_table_storage batched broker gateway git gcp_bigquery_select gcp_cloud_storage gcp_pubsub gcp_spanner_cdc generate http_client http_server inproc kafka kafka_franz microsoft_sql_server_cdc mongodb_cdc mongodb mqtt mysql_cdc nats nats_jetstream nats_kv oracledb_cdc otlp_grpc otlp_http postgres_cdc read_until redis_list redis_pubsub redis_scan redis_streams redpanda redpanda_common redpanda_migrator resource salesforce salesforce_cdc salesforce_graphql schema_registry sequence sftp slack slack_users spicedb_watch splunk sql_raw sql_select timeplus outputs amqp_0_9 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 broker cache cyborgdb drop drop_on elasticsearch_v8 fallback gcp_bigquery gcp_bigquery_write_api gcp_cloud_storage gcp_pubsub iceberg http_client inproc kafka kafka_franz mongodb mqtt nats nats_jetstream nats_kv otlp_grpc otlp_http opensearch pinecone 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 splunk_hec sql_insert sql_raw switch sync_response timeplus processors a2a_message archive avro aws_bedrock_chat aws_bedrock_embeddings aws_dynamodb_partiql aws_lambda azure_cosmosdb benchmark bloblang bounds_check branch cache cached catch cohere_chat cohere_embeddings cohere_rerank compress decompress dedupe for_each gcp_bigquery_select gcp_vertex_ai_chat gcp_vertex_ai_embeddings google_drive_download google_drive_list_labels google_drive_search group_by group_by_value http insert_part jira jmespath jq json_schema log mapping metric mongodb 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_decode parquet_encode parse_log processors protobuf qdrant rate_limit redis redis_script resource retry schema_registry_decode schema_registry_encode select_parts slack_thread sleep split sql_insert sql_raw sql_select string_split switch sync_response text_chunker try try_catch unarchive while workflow xml caches aws_dynamodb aws_s3 gcp_cloud_storage lru memcached memory mongodb multilevel nats_kv noop redis redpanda ristretto sql ttlru rate limits local redis buffers memory none system_window scanners avro chunker csv decompress json_array json_documents lines re_match skip_bom switch tar to_the_end tracers gcp_cloudtrace none open_telemetry_collector redpanda metrics none open_telemetry_collector prometheus redpanda logger guides bloblang bloblang walkthrough bloblang functions bloblang methods bloblang arithmetic cloud credentials amazon web services authenticate to amazon aurora using iam roles google cloud platform ingest real time sensor telemetry with the http gateway synchronous responses migrate to the unified redpanda migrator cookbooks dynamodb cdc patterns enrichment workflows filtering and sampling ingest data into snowflake joining streams redpanda migrator retrieval augmented generation rag work with jira issues redpanda sql get started quickstart enable redpanda sql redpanda sql overview oltp vs olap redpanda sql vs postgresql connect to redpanda sql authenticate psycopg2 java jdbc php pdo c dapper npgsql query data sql editor redpanda catalogs query streaming topics query iceberg enabled topics query topics with nested fields manage redpanda sql manage access troubleshoot degraded state handling query out of memory errors develop kafka compatibility topics overview manage topics manage cloud topics configure producers for cloud topics produce data configure producers idempotent producers configure leader pinning consume data consumer offsets follower fetching paginate messages in redpanda console use redpanda with the http proxy api cloud management mcp server redpanda cloud management mcp server redpanda cloud management mcp server quickstart configure the redpanda cloud management mcp server data transforms overview build configure deploy test monitor manage transactions kafka connect converters and serialization monitor connectors disable kafka connect single message transforms sizing connectors aws s3 sink connector google bigquery sink connector gcs sink connector iceberg sink connector jdbc sink connector jdbc source connector mirrormaker2 source connector mirrormaker2 checkpoint connector mirrormaker2 heartbeat connector mongodb sink connector mongodb source connector mysql debezium source connector postgresql debezium source connector sql server debezium source connector snowflake sink connector manage manage your organization redpanda cli introduction to rpk install or update rpk specify broker addresses for rpk rpk profiles cluster maintenance cluster state upgrades and maintenance configure cluster properties audit logging sample audit log messages about client throughput quotas manage throughput configure client connections mountable topics iceberg about iceberg topics migrate to iceberg topics specify iceberg schema use iceberg catalogs integrate with rest catalogs aws glue databricks unity catalog gcp lakehouse snowflake and open catalog query iceberg topics migrate iceberg catalogs tune performance for iceberg topics troubleshoot iceberg topics schema registry redpanda schema registry use schema registry use the schema registry api schema registry authorization schema registry contexts schema id validation deserialization programmable push filters edit topic configuration disaster recovery shadowing overview configure shadowing monitor shadowing failover failover runbook cloud api use the control plane api byoc dedicated serverless use the data plane apis redpanda terraform provider monitor redpanda cloud networking network design and ports choose cidr ranges serverless aws configure privatelink in the cloud console configure privatelink with the cloud api byoc aws add a peering connection configure privatelink in the cloud console configure privatelink with the cloud api add a transit gateway configure centralized egress create an aws hub for centralized egress azure configure azure private link in the cloud console configure azure private link with the cloud api gcp add a peering connection configure private service connect in the cloud console configure private service connect with the cloud api enable global access configure centralized egress create a gcp hub for centralized egress dedicated aws add a peering connection configure privatelink in the cloud console configure aws privatelink with the cloud api azure configure private link in the cloud console configure azure private link with the cloud api gcp add a peering connection configure private service connect in the cloud console configure private service connect with the cloud api security authentication authorization cloud authorization role based access control rbac configure rbac in the control plane configure rbac in the data plane group based access control gbac configure gbac in the control plane configure gbac in the data plane access control lists acls aws iam policies gcp iam policies azure iam policies encryption availability secrets safety and reliability billing billing and support manage payment methods view billing activity manage billing notifications aws use commits use pay as you go azure use commits gcp use commits use pay as you go partner integrations reference redpanda sql reference keywords comment support sql schemas statements alter iceberg catalog alter redpanda catalog alter storage alter table alter user copy to create iceberg catalog create redpanda catalog create storage create table create user describe drop iceberg catalog drop redpanda catalog drop storage drop table drop user grant revoke select set and show show catalogs show execs show nodes show queries show tables clauses set operations except intersect union from from join left join outer join right join group by having limit offset order by over and window where with data types array bool bytea date geography geometry interval json numeric numeric data type aliases row text time time operators timestamp with time zone timestamp without time zone functions aggregate ordered set mode percentile_cont percentile_disc statistics corr covar_pop covar_samp regr_avgx regr_avgy regr_count regr_intercept regr_r2 regr_slope regr_sxx regr_sxy regr_syy stddev stddev_pop stddev_samp var_pop var_samp variance avg bool_and bool_or count distinct for_max for_min max min sum boolean if is distinct from is not distinct from json json_array_extract json_array_length json_extract_path json_extract_path_text math abs cbrt ceil cosh exp floor greatest least ln log power random round sign sin sinh sqrt to_char number other coalesce col_description current_database current_schema generate_series has_schema_privilege nullif obj_description pg_backend_pid pg_encoding_to_char pg_get_constraintdef pg_get_expr pg_get_indexdef pg_get_statisticsobjdef_columns pg_get_userbyid pg_relation_is_publishable pg_size_pretty pg_table_is_visible pg_table_size pg_total_relation_size pg_typeof shobj_description string regex posix regular expressions regexp_match regexp_replace concat ends_with length lower position replace starts_with strpos substring upper timestamp current_timestamp date_trunc extract format_timestamp timestamp_micros timestamp_millis timestamp_seconds timestamp_trunc to_char to_timestamp unix_micros unix_millis unix_seconds window avg bool_and bool_or count cume_dist dense_rank first_value lag last_value lead max min nth_value ntile percent_rank rank row_number sum operators bitwise shift left bitwise shift right system catalogs pg_attrdef pg_attribute pg_authid pg_class pg_constraint pg_database pg_depend pg_description pg_index pg_language pg_namespace pg_proc pg_roles pg_settings pg_shadow pg_statio_user_tables pg_type pg_user information schema system virtual tables transactions cloud tiers and regions serverless regions byoc tiers and regions dedicated tiers and regions api reference properties cluster configuration properties object storage properties data transforms sdks golang rust javascript data transforms api schema registry api rpk commands rpk rpk x rpk cloud rpk cloud auth rpk cloud auth delete rpk cloud auth list rpk cloud auth token rpk cloud auth use rpk cloud byoc rpk cloud byoc install rpk cloud byoc uninstall rpk cloud cluster rpk cloud cluster select rpk cloud login rpk cloud logout rpk cloud mcp rpk cloud mcp install rpk cloud mcp stdio rpk cluster rpk cluster config rpk cluster config get rpk cluster config list rpk cluster config set rpk cluster config status rpk cluster connections rpk cluster connections list rpk cluste...
|
