Meta tags:
description=Learn how to process periodic windows of messages with Redpanda Connect.;

Headings (most frequently used words):

you, this, page, let, us, windowed, processing, creating, windows, grouping, aggregating, simple, online, edits, contribution, guide, components, highlight, hit, preview, attribute, title, what, do, think, of, know, more, contact, about, your, feedback, endpoint, example, on,

Text of the page (most frequently used words):
rpk (150), the (70), cloud (64), item (58), #preview (54), api (45), redpanda (45), cluster (40), html (34), state (31), return (29), data (29), registry (29), configure (28), with (27), and (27), for (26), context (24), security (23), const (22), create (22), product (21), connect (20), list (20), window (19), schema (18), components (17), this (16), query (16), doc (15), hit (15), attribute (15), profile (15), iceberg (15), connector (15), reference (14), index (14), use (14), topics (14), delete (14), algolia (13), sql (13), topic (12), aws (12), manage (12), https (11), www (11), com (11), title (11), storage (11), byoc (11), gcp (11), streaming (10), plane (10), set (10), objectid (10), group (10), azure (10), let (9), server (9), map (9), private (9), you (9), processing (9), messages (9), describe (9), shadow (9), catalog (9), results (8), show (8), get (8), componenttitle (8), platform (8), parameters (8), time (8), type (8), add (8), open (8), about (8), breadcrumbs (8), snippet (8), intro (8), description (8), your (8), bloblang (8), mcp (8), user (8), role (8), console (8), method (7), url (7), root (7), our (7), docs (7), overview (7), length (7), text (7), breadcrumb (7), highlight (7), each (7), traffic_light (7), windows (7), transform (7), alter (7), config (7), control (7), sink (7), path (6), new (6), link (6), version (6), facet (6), selected (6), titles (6), search (6), algoliabtn (6), event (6), queryid (6), positions (6), status (6), from (6), json (6), buffer (6), kafka (6), generate (6), catalogs (6), drop (6), privatelink (6), source (6), mongodb (6), not (5), origin (5), all (5), that (5), exact (5), match (5), sources (5), plugin (5), hits (5), nestedhits (5), docindices (5), can (5), function (5), ask (5), stoppropagation (5), clickedobjectidsaftersearch (5), eventname (5), __autocomplete_indexname (5), __autocomplete_queryid (5), objectids (5), activeitemid (5), href (5), message (5), edit (5), batch (5), passengers (5), traffic (5), windowed (5), configuration (5), build (5), secret (5), compatibility (5), mode (5), quotas (5), auth (5), log (5), access (5), monitor (5), management (5), currentquery (4), view (4), managed (4), home (4), see (4), filters (4), _tags (4), content (4), autocomplete (4), null (4), none (4), clickanalytics (4), true (4), matchingheading (4), tolowercase (4), click (4), target (4), feedback (4), mapping (4), from_all (4), processors (4), group_by_value (4), is_first_message (4), created_at (4), sum (4), stream (4), into (4), system_window (4), system (4), update (4), acl (4), install (4), txn (4), producers (4), mount (4), transforms (4), properties (4), http (4), dedicated (4), regions (4), serverless (4), join (4), billing (4), iam (4), service (4), peering (4), connection (4), centralized (4), egress (4), enable (4), quickstart (4), broker (4), switch (4), nats_kv (4), byovpc (4), example (3), hasendpoint (3), endpointline (3), curlexample (3), try (3), self (3), agentic (3), fallback (3), getitems (3), header (3), right (3), render (3), values (3), libraries (3), getalgoliafacets (3), queries (3), params (3), phrase (3), which (3), false (3), getalgoliaresults (3), order (3), items (3), foreach (3), _highlightresult (3), matchedindex (3), matchedtopleveltitle (3), has (3), renderproduct (3), array (3), seen (3), within (3), supported_preview_types (3), includes (3), document (3), btn (3), addeventlistener (3), slice (3), know (3), select (3), page (3), contribution (3), want (3), perform (3), count (3), first (3), pipeline (3), value (3), against (3), methods (3), field (3), will (3), emitted (3), light (3), more (3), produce (3), complete (3), deploy (3), failover (3), subject (3), level (3), globals (3), connections (3), tiers (3), timestamp (3), distinct (3), table (3), commits (3), secrets (3), policies (3), gbac (3), rbac (3), authorization (3), gateway (3), shadowing (3), migrate (3), snowflake (3), introduction (3), debezium (3), mirrormaker2 (3), jdbc (3), connectors (3), memory (3), redis (3), gcp_cloud_storage (3), aws_s3 (3), sql_raw (3), resource (3), azure_cosmosdb (3), pipelines (3), endpoint (2), enrichment (2), catch (2), integrate (2), current (2), askaibutton (2), viewalllink (2), strict (2), typo (2), exacttoggle (2), tags (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), returns (2), __algoliatoggleexactmatch (2), exactmatch (2), exactparams (2), hitsperpage (2), attributestosnippet (2), snippetellipsistext (2), tagfilters (2), while (2), are (2), nondocitems (2), filter (2), unixtimestamp (2), infinity (2), nondocindex (2), full (2), clear (2), stale (2), navigate (2), atag (2), setcontext (2), ctx (2), other (2), dropdown (2), without (2), references (2), autocompleteinstance (2), button (2), action (2), var (2), queryselector (2), detachedsearchbutton (2), key (2), _blank (2), rel (2), noopener (2), noreferrer (2), openchatwithquery (2), policy (2), metadata (2), batching (2), thanks (2), thumb_down (2), thumb_up (2), was (2), helpful (2), work (2), read (2), guide (2), issue (2), github (2), simple (2), such (2), using (2), wide (2), only (2), handy (2), registration_plate (2), unique (2), aggregated (2), step (2), cars (2), purpose (2), following (2), single (2), out (2), options (2), group_by (2), information (2), input (2), addresses (2), therefore (2), producing (2), creating (2), cbf2eafc (2), 806e (2), 4067 (2), 9211 (2), 97be7e42cee3 (2), 2021 (2), made (2), aggregate (2), analysis (2), where (2), copy (2), metrics (2), consume (2), print (2), uninstall (2), offset (2), mountable (2), logdirs (2), proxy (2), apis (2), transactions (2), tables (2), bitwise (2), shift (2), left (2), operators (2), min (2), max (2), bool_or (2), bool_and (2), avg (2), to_char (2), functions (2), zone (2), numeric (2), support (2), pay (2), based (2), authentication (2), hub (2), errors (2), troubleshoot (2), specify (2), client (2), throughput (2), audit (2), maintenance (2), cli (2), postgresql (2), google (2), handling (2), authenticate (2), started (2), jira (2), migrator (2), streams (2), ingest (2), real (2), amazon (2), open_telemetry_collector (2), decompress (2), avro (2), noop (2), aws_dynamodb (2), sync_response (2), sql_select (2), sql_insert (2), retry (2), qdrant (2), gcp_bigquery_select (2), cache (2), timeplus (2), sftp (2), schema_registry (2), redpanda_migrator (2), redpanda_common (2), redis_streams (2), redis_pubsub (2), redis_list (2), otlp_http (2), otlp_grpc (2), nats_jetstream (2), nats (2), mqtt (2), kafka_franz (2), inproc (2), http_client (2), gcp_pubsub (2), azure_table_storage (2), azure_queue_storage (2), azure_blob_storage (2), aws_sqs (2), aws_kinesis (2), amqp_0_9 (2), what (2), documentation (2), labs (2), txt (2), tiny, reduce, clicks, pure, required, touppercase, curl, assistant, compose, respects, productparams, shows, products, 20data, 20plane, toggle, forces, layout, side, footer, tips, define, used, actual, core, concepts, getsources, groupby, tagsplugin, fetch, populate, menu, raw, facets, known, happens, when, require, spelling, optional, word, note, deliberately, wrap, quotes, searchable, attributes, unordered, disables, proximity, quoted, 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, panel, otherwise, tab, getitemurl, onactive, expose, instance, globally, custom, drive, its, capturing, across, renders, intentionally, namespaced, notes, below, __algoliaautocompleteinstance, wire, sidebar, modal, clicking, hidden, detached, queryselectorall, keydown, enter, preventdefault, domcontentloaded, initalgolia, answers, may, imprecise, always, verify, any, believe, should, close, esc, image, analytics, requires, start, children, checked, typeof, setisopen, cookie, preferences, trust, terms, privacy, 2026, inc, rights, reserved, make, group_add, share, mail, community, extensive, updates, prefer, locally, something, change, changes, fixing, directly, online, edits, back, top, very, powerful, possible, range, fancy, challenge, updating, above, journey, registration, plate, hint, might, come, fold, batch_index, window_end_timestamp, total_cars, keep, containing, deleted, once, been, grouped, next, calculate, passenger, counts, comes, executes, entire, allowing, mutate, result, chained, language, aggregating, case, chosen, periodically, batches, fit, since, analyse, separately, need, expand, one, identifier, have, two, processor, grouping, refer, todo, traffic_data, consumer_group, traffic_consumer, checkpoint_limit, 1000, timestamp_mapping, size, allowed_lateness, creates, clock, running, machine, created, predictable, times, but, also, means, historic, prevents, backfills, themselves, done, configuring, after, 07t10, 00z, unique_cars, windowing, allows, representing, total, hour, 07t09, 35z, ab1c, def, given, relating, passing, through, various, lights, respect, able, analyze, useful, dataset, never, collection, must, continuous, feed, collections, code, plain, copied, markdown, checking, glossary, logs, init, trim, prefix, partitions, unassign, assign, check, reset, rename, prompt, help, seek, shell, completion, grafana, dashboard, app, unmount, cancel, import, info, stdio, logout, login, token, commands, javascript, rust, golang, sdks, object, virtual, 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, power, 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, row, aliases, interval, geometry, geography, date, bytea, bool, types, over, limit, having, outer, intersect, except, operations, clauses, nodes, execs, revoke, grant, statements, schemas, comment, keywords, partner, integrations, notifications, activity, payment, safety, reliability, availability, encryption, lists, acls, global, transit, choose, cidr, ranges, network, design, ports, networking, terraform, provider, deprecation, codes, runbook, disaster, recovery, programmable, push, deserialization, validation, contexts, tune, performance, lakehouse, databricks, unity, glue, rest, sample, logging, upgrades, profiles, organization, mysql, heartbeat, checkpoint, gcs, bigquery, sizing, disable, converters, serialization, test, paginate, follower, fetching, consumer, offsets, leader, pinning, idempotent, develop, degraded, nested, fields, enabled, editor, dapper, npgsql, php, pdo, java, psycopg2, oltp, olap, issues, retrieval, augmented, generation, rag, joining, filtering, sampling, workflows, dynamodb, cdc, patterns, cookbooks, unified, synchronous, responses, sensor, telemetry, aurora, roles, web, services, credentials, arithmetic, walkthrough, guides, logger, prometheus, gcp_cloudtrace, tracers, to_the_end, tar, skip_bom, re_match, lines, json_documents, json_array, csv, chunker, scanners, buffers, local, rate, limits, ttlru, ristretto, multilevel, memcached, lru, caches, xml, workflow, unarchive, try_catch, text_chunker, string_split, split, sleep, slack_thread, select_parts, schema_registry_encode, schema_registry_decode, redis_script, rate_limit, protobuf, parse_log, parquet_encode, parquet_decode, parallel, openai_translation, openai_transcription, openai_speech, openai_image_generation, openai_embeddings, openai_chat_completion, ollama_moderation, ollama_embeddings, ollama_chat, nats_request_reply, mutation, metric, json_schema, jmespath, insert_part, google_drive_search, google_drive_list_labels, google_drive_download, gcp_vertex_ai_embeddings, gcp_vertex_ai_chat, for_each, dedupe, compress, cohere_rerank, cohere_embeddings, cohere_chat, cached, branch, bounds_check, benchmark, aws_lambda, aws_dynamodb_partiql, aws_bedrock_embeddings, aws_bedrock_chat, archive, a2a_message, splunk_hec, snowflake_streaming, snowflake_put, slack_reaction, slack_post, salesforce_sink, reject_errored, reject, redis_hash, questdb, pinecone, opensearch, gcp_bigquery_write_api, gcp_bigquery, elasticsearch_v8, drop_on, cyborgdb, azure_data_lake_gen2, aws_sns, aws_kinesis_firehose, arc, outputs, splunk, spicedb_watch, slack_users, slack, sequence, salesforce_graphql, salesforce_cdc, salesforce, redis_scan, read_until, postgres_cdc, oracledb_cdc, mysql_cdc, mongodb_cdc, microsoft_sql_server_cdc, http_server, gcp_spanner_cdc, git, batched, aws_dynamodb_cdc, aws_cloudwatch_logs, inputs, unit, testing, resources, process, paths, interpolation, contextual, variables, error, remote, replicas, byovnet, architecture, how, works, hundreds, deployments, run, own, infrastructure, fully, foundation, everything, agents, please, robot, before, submitting, submit, contact, think, beep, boop, bot, here, familiar, syntax, learn, component, specific, llms,

Text of the page (random words):
e 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 control plane api data plane apis http proxy api schema registry api 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 cluster logdirs rpk cluster logdirs describe rpk cluster info rpk cluster quotas rpk cluster quotas alter rpk cluster quotas describe rpk cluster quotas import rpk cluster storage rpk cluster storage cancel mount rpk cluster storage list mount rpk cluster storage list mountable rpk cluster storage mount rpk cluster storage status mount rpk cluster storage unmount rpk cluster txn rpk cluster txn describe rpk cluster txn describe producers rpk cluster txn list rpk generate rpk generate app rpk generate grafana dashboard rpk generate shell completion rpk group rpk group delete rpk group offset delete rpk group describe rpk group list rpk group seek rpk help rpk plugin rpk plugin list rpk plugin uninstall rpk plugin install 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 registry rpk registry compatibility level rpk registry compatibility level get rpk registry compatibility level set rpk registry context rpk registry context list rpk registry context delete 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 secret rpk security secret create rpk security secret delete rpk security secret list rpk security secret update rpk security user rpk security user create rpk security user delete rpk security user update rpk security user list rpk shadow 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 consume rpk topic create rpk topic delete rpk topic describe 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 version metrics reference glossary status checking was this helpful thumb_up thumb_down thanks for your feedback home data platform cloud redpanda connect configuration windowed processing cloud page options copy as markdown copied view as plain text ask ai about this topic add mcp server to vs code windowed processing a window is a batch of messages made with respect to time with which we are able to perform processing that can analyze or aggregate the messages of the window this is useful in stream processing as the dataset is never complete and therefore in order to perform analysis against a collection of messages we must do so by creating a continuous feed of windows collections where our analysis is made against each window for example given a stream of messages relating to cars passing through various traffic lights traffic_light cbf2eafc 806e 4067 9211 97be7e42cee3 created_at 2021 08 07t09 49 35z registration_plate ab1c def passengers 3 windowing allows us to produce a stream of messages representing the total traffic for each light every hour traffic_light cbf2eafc 806e 4067 9211 97be7e42cee3 created_at 2021 08 07t10 00 00z unique_cars 15 passengers 43 creating windows the first step in processing windows is producing the windows themselves this can be done by configuring a window producing buffer after your input system a system_window buffer creates windows by following the system clock of the running machine windows will be created and emitted at predictable times but this also means windows for historic data will not be emitted and therefore prevents backfills of traffic data input kafka addresses todo topics traffic_data consumer_group traffic_consumer checkpoint_limit 1000 buffer system_window timestamp_mapping root this created_at size 1h allowed_lateness 3m for more information about this buffer refer to the system_window buffer docs grouping with a window buffer chosen our stream of messages will be emitted periodically as batches of all messages that fit within each window since we want to analyse the window separately for each traffic light we need to expand this single batch out into one for each traffic light identifier within the window for that purpose we have two processor options group_by and group_by_value in our case we want to group by the value of the field traffic_light of each message which we can do with the following pipeline processors group_by_value value json traffic_light aggregating once our window has been grouped the next step is to calculate the aggregated passenger and unique cars counts for this purpose the redpanda connect mapping language bloblang comes in handy as the method from_all executes the target function against the entire batch and returns an array of the values allowing us to mutate the result with chained methods such as sum pipeline processors group_by_value value json traffic_light mapping let is_first_message batch_index 0 root traffic_light this traffic_light root created_at window_end_timestamp root total_cars if is_first_message json registration_plate from_all unique length root passengers if is_first_message json passengers from_all sum only keep the first batch message containing the aggregated results root if is_first_message deleted bloblang is very powerful and by using from and from_all it s possible to perform a wide range of batch wide processing if you fancy a challenge try updating the above mapping to only count passengers from the first journey of each registration plate in the window hint the fold method might come in handy back to top simple online edits for simple changes such as fixing a typo you can edit the content directly on github edit on github or open an issue to let us know about something that you want us to change open an issue contribution guide for extensive content updates or if you prefer to work locally read our contribution guide was this helpful thumb_up thumb_down group ask in the community mail share your feedback group_add make a contribution thanks for your feedback message batching metadata 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 cloud 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 pr...