Built for engineers and testers who actually use Kafka
From live feeds and historical multi-topic forensics to XML filtering, cloud-synced working data, message sending, samples, and playbooks, Kafka Streamyard is built for real investigation and manual test workflows.
KS philosophy: Kafka Streamyard is built around a simple idea: give you the easy-to-use features you wish were already in your current Kafka UI. Whether you are a developer, tester, DevOps engineer, or an authorized business user, if something is missing, tell us — we want KS to keep getting better and become the bee's knees.
SL Filters, autocomplete, history, saving
Build reusable Streamyard Language (SL) filters with colorized autocomplete for JSON or XML messages, keys, headers, and record metadata. Test and save filters for reuse across topics and environments, browse cloud-synced valid history, and optionally use AI to help generate queries.
Take your Kafka working set between computers
Cloud-sync criteria presets, topic-list filters, valid filter histories, custom result views, playbooks, data samples, folders, and Live Views through Bunny Storage. Connections, credentials, result caches, and current Session filter text remain local.
Use one filter language across structured data
Filter deeply nested JSON or namespaced XML messages and keys with the same SL paths, autocomplete, history, and syntax highlighting. Work with repeated XML elements, attributes, mixed text, numeric comparisons, and collection predicates without switching tools.
Persisted async playback you can filter
Run many playbacks asynchronously for larger topics while you do other work. Results stay persisted so you can return later, with message and key formats recognised automatically—including supported Confluent schemas. Use the offset function to narrow the data you retrieve.
Column builder + CSV reports
Build the result view you want, choose the JSON or XML fields that matter, add calculated columns, and export a CSV report using the same columns you see in the grid.
JSON, NDJSON, XML, CSV, and KS envelopes
Import or export JSON arrays, JSON objects, NDJSON, raw XML records, and CSV reports. JSON and NDJSON envelopes preserve XML payload text, optional keys, headers, and partitions so structured data can move safely between investigation and test workflows.
Find the topics you need fast in large clusters
In large systems with thousands of topics, keep the topic list focused with advanced saved filters, tag them to related dev, test or prod clusters. In addition, Right-click on a topic to reveal dozens of useful options.
Turn playback into a quick live feed
Turn a playback into a quick live feed when you want to watch messages arrive in real time, or let it run and come back later. Use the same SL filtering so the live feed stays focused on the messages that matter.
Investigate and reconstruct multi-topic flows
Follow up to 30 topics as one chronological live timeline, or replay a precise historical window for incident investigation and forensic analysis. Combine tested per-topic filters with a Session filter, then use Received and Shown counts plus the activity-aware Flow Chart to trace the wider process.
Copy topic data and run repartition tasks
Copy topic data (like file manager) between environments, with schema-aware handling, and run repartition tasks when you need a different partition layout on the destination.
Playbook builder and dry-run scripts
Generate line-based playbooks from selected topics, preview them with dry run, and automate create, copy, clear, delete, config, and import-data workflows safely.
Inspect, edit, copy, and send messages
Use the Message Details panel to inspect message history, edit key, value, and headers, copy the full KS message format or individual parts, and send messages back to a topic for manual testing.
Organise samples for manual testing
Save useful messages directly into reusable samples, organise them for the order you want to send them in, and keep manual test workflows ready for replay after a fix.
Parent samples and stable or regenerated values
Use session variables with parent samples, inheritance, and recalc controls so IDs can stay stable across a workflow or regenerate on every send when needed from the message details panel.
Variable substitution and business data generators
Use @@ generators and references across headers, key, and message to create realistic people, orders, invoices, shipments, devices, and more without maintaining hand-written payload files.
Quantity, wait-time, and partitioning controls
Load batches of sample messages with configurable quantity, pacing, bursts, and partitioning strategies so repeatable playback matches the test you are running.
Background jobs you can come back to
Use the task system to run long operations in the background, including copy topic data (like file manager), export jobs, playbooks, randomized sample loaders, and repartitioning, while keeping progress and output visible in one place.
Topic information and audit views
Audit topic information at a glance, inspect consumer offset controls, ISR data, configuration, and additional Kafka Streamyard metadata or overrides, and keep operational context close while you investigate data and configuration together.
Examine exactly the slice of data you need
Use comprehensive offset functions to inspect yesterday’s data, absolute time ranges, offsets, head/tail windows, or a specific message count per partition when you need precise investigations over large topics.
Cluster dashboard, consumers, ACLs, and Connect
Inspect cluster health and disk usage, review all consumers or per-topic lag, reset offsets when needed, troubleshoot Kafka ACLs, and manage Kafka Connect from the same desktop workflow.
Schema Registry and schema-aware exploration
Browse schemas, understand payload shape before producing or consuming, and use schema-aware context to inspect data more confidently and seed smarter workflows.
One desktop app for real Kafka workflows
Filter & stream
Use colorized SL filters across JSON and XML with autocomplete, cloud-synced history, and saving, then move between playback, live feeds, and multi-topic Live Views to focus on exactly the events you care about.
Inspect & export
Work with persisted playback results, auto-detect JSON and XML formats, inspect schemas, build result columns, and export JSON, NDJSON, XML-preserving envelopes, or CSV reports without leaving the investigation flow.
Replay & automate
Capture samples, organize favorites, run async playback, create playbooks, copy topic data (like file manager), and track long-running jobs in the background while you work on something else.
Operate safely
Use enhanced topic organisation, manage topics, repartition when needed, inspect consumers and ACLs, and keep investigations open across windows and persisted result sets.
Download and start in minutes
Install the desktop app and connect to your clusters.
Download