Take control of Apache Kafka® with kPow.
Discover the full feature set of the kPow Kafka toolkit and learn all the ways that kPow will empower your team to do Kafka better. Built with Kafka, by a team of experts, kPow is rapidly becoming the number one tool for modern enterprise engineers.
Unlimited Users. Unlimited Features.
All paid kPow Licenses are priced per cluster, include the full feature set and have no restrictions on users.
kPow includes a suite of exclusive features. Everything marked with an is only available in kPow.
Kafka Management
Use kPow to monitor and control all of your Kafka resources.
Kafka Topics
All the topic information you need, from leader disk to under-replicated partitions.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Topic Summary | At a glance information on key metrics and health of topics in your cluster/s. | ✔️ | ✔️ |
| Visualise Topics | Charting for topic consumption, production, disk-usage, partition distribution and more. | ✔️ | ✔️ |
| View Topic Metrics | In-depth metrics for every topic and topic partition, including broker distribution and consumption. | ✔️ | ✔️ |
| Topic Live Mode | View topic graphs and metrics continuously in near real-time. | ✔️ | ✔️ |
| Export Topic Metrics | All metrics are available for export via Prometheus endpoints. | ✔️ | |
| Create Topic Alerts | See our guide to alerting on exported metrics with Prometheus AlertManager, New Relic, etc. | ✔️ | |
| Filter and Compare Topics | Find the right topics quickly with our easy UI filters. | ✔️ | ✔️ |
| Advanced Topic Filters | Filter topics by number of messages or topic inactivity. | ✔️ | ✔️ |
| Create Topics | Quickly create new topics with the option to copy existing topic configuration. | ✔️ | ✔️ |
| Delete Topics | Delete topics with a single click. | ✔️ | ✔️ |
| Edit Topics | Check configuration with built in documentation and easily edit all topic options. | ✔️ | ✔️ |
| Secure Topics | Create, clone, and delete Kafka ACLs at a topic level. | ✔️ | ✔️ |
| Identify Inactive Topics | kPow monitors and reports inactivity to a topic partition level. | ✔️ | ✔️ |
| Identify Under Replicated Partitions | Quickly identify topic partitions that have fewer than RF replicas. | ✔️ | ✔️ |
| View Topic Data | Our Data UI provides fast, powerful topic exploration. | ✔️ | ✔️ |
| Produce Topic Data | Create new messages or reproduce message to the same or new topics. | ✔️ | ✔️ |
| Batch Edit (coming soon) | Update or standardise multiple topics with new configuration at once. | ✔️ | ✔️ |
Kafka Consumer
Multi-dimensional insight into consumer activity in your clusters.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Consumer Summary | At a glance information on key metrics and health of consumer groups in your cluster/s. | ✔️ | ✔️ |
| Visualise Consumers | Charting for consumer lag, state, consumption rates, and more. | ✔️ | ✔️ |
| View Consumer Metrics | In-depth metrics for every consumer, consumer member, and member assignment. | ✔️ | ✔️ |
| Visualise Consumer Topologies | Topology viewer of each consumer group with live lag and consumption details. | ✔️ | ✔️ |
| Manage Consumer Offsets | Skip group offsets, reset them to a point in time, or clear them entirely at group, host, topic, member, or assignment level. | ✔️ | ✔️ |
| Visualise Topic Consumption | Charting for topic consumption and aggregated lag of consumers to a topic. | ✔️ | ✔️ |
| View Consumer Topic Metrics | In-depth consumption metrics for every topic in your cluster to a topic member assignment level. | ✔️ | ✔️ |
| Visualise Broker Consumption | Charting for broker consumption and aggregated lag of consumers to a broker. | ✔️ | ✔️ |
| View Consumer Broker Metrics | In-depth consumption metrics for every broker in your cluster to a broker member assignment level. | ✔️ | ✔️ |
| Visualise Consumer Hosts | Charting for consumption and lag by the network host of consumers groups. | ✔️ | ✔️ |
| View Consumer Host Metrics | In-depth metrics for consumer groups aggregated by the network host that serves them. | ✔️ | ✔️ |
| Consumer Live Mode | View consumer graphs and metrics continuously in near real-time. | ✔️ | ✔️ |
| Export Consumer Metrics | All metrics are available for export via Prometheus endpoints. | ✔️ | |
| Export Consumer Offsets | All offsets are available for export via Prometheus endpoints. | ✔️ | |
| Create Consumer Alerts | See our guide to alerting on exported metrics with Prometheus AlertManager, New Relic, etc. | ✔️ | |
| Filter and Compare Consumers | Find the right consumers quickly with our easy UI filters. | ✔️ | ✔️ |
| Advanced Filters | Filter topics by group state, consumer lag, or group inactivity. | ✔️ | ✔️ |
| Delete Consumers | Delete consumer groups with a single click. | ✔️ | ✔️ |
| Secure Consumers | Create, clone, and delete Kafka ACLs at a consumer group level. | ✔️ | ✔️ |
| Identify Inactive Consumers | kPow monitors and reports inactivity to a consumer group member assignment level. | ✔️ | ✔️ |
| View Group Data | Our Data UI provides fast, powerful topic exploration from a group perspective. | ✔️ | ✔️ |
Kafka Brokers
Quickly identify unbalanced brokers and understand how your data is physically distributed.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Broker Summary | At a glance information on key metrics and health of brokers in your cluster/s. | ✔️ | ✔️ |
| Visualise Brokers | Charting for broker disk, consumption, production, balance, and more. | ✔️ | ✔️ |
| View Broker Metrics | In-depth metrics for every broker and broker topic distribution. | ✔️ | ✔️ |
| Export Broker Metrics | All metrics are available for export via Prometheus endpoints. | ✔️ | |
| Create Broker Alerts | See our guide to alerting on exported metrics with Prometheus AlertManager, New Relic, etc. | ✔️ | |
| Filter and Compare Brokers | Find the right brokers quickly with our easy UI filters. | ✔️ | ✔️ |
| Edit Brokers | Check configuration with built in documentation and easily edit all broker options. | ✔️ | ✔️ |
| Secure Clusters | Create, clone, and delete Kafka ACLs at a principal, resource, host, or control level. | ✔️ | ✔️ |
Kafka ACL Security
Secure your clusters with first class support for Kafka ACLs.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| ACL Summary | At a glance information on key metrics ACLs in your cluster/s. | ✔️ | ✔️ |
| View ACLs | In-depth information on your ACLs by topic, group, principal, host, and resource. | ✔️ | ✔️ |
| Create ACLs | Create a new Kafka ACL. | ✔️ | ✔️ |
| Delete ACLs | Delete an existing Kafka ACL. | ✔️ | ✔️ |
| Clone ACLs | Clone (and change) an existing Kafka ACL. | ✔️ | ✔️ |
Kafka Connectivity
kPow is built from standard Apache Kafka clients.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Any Brokers / Cluster | kPow is compatible with Kafka 1.0+, Confluent Cloud, AMQ Streams, and Azure Event Hubs. | ✔️ | ✔️ |
| Client Connections | All standard Kafka connection options supported, including PLAINTEXT, SASL_PLAINTEXT, SASL_SSL, and SSL. | ✔️ | ✔️ |
| Confluent Cloud | kPow provides extended metrics for Confluent Cloud including active connections and disk-use. | ✔️ | ✔️ |
Kafka Insights
Derived insights about your connected Kafka resources.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Message Distribution | Visualisation of message distribution and balance throughout your cluster/s. | ✔️ | ✔️ |
| Active Topics | Top-5 most active topics. | ✔️ | ✔️ |
| Active Groups | Top-5 most active consumer groups. | ✔️ | ✔️ |
| Disk Usage (coming soon) | Analysis of disk consumption vs remaining capacity. | ✔️ | ✔️ |
| Poison Pill Detection (coming soon) | Analysis of consumer group consumption and detection of stalled partitions. | ✔️ | ✔️ |
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Streams Summary | At a glance information on key metrics and health your Kafka Streams applications. | ✔️ | ✔️ |
| Visualise Streams | Charting for streams consumption and lag. | ✔️ | ✔️ |
| Visualise Streams Topologies | Topology viewer of each Kafka Streams application to a streams function level with live metrics. | ✔️ | ✔️ |
| View Streams Metrics | In-depth metrics for every Kafka Streams application to a RocksDB level. | ✔️ | ✔️ |
| Open Source Streams Agent | Easily configured with your Streams applications to unlock all of kPows Streams features. | ✔️ | ✔️ |
| Automatic Streams Detection | kPow automatically detects Consumer Groups that fit known Kafka Streams naming patterns. | ✔️ | ✔️ |
Schema Registry
Make sense of schemas and subjects, from visual diffs to compatibility updates.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Schema and Subject Summary | At a glance information about all Schema and Subjects in your Schema Registry. | ✔️ | ✔️ |
| Create Subjects | Create new Subjects in your Schema Registry. | ✔️ | ✔️ |
| Delete Subjects | Delete subjects in a single click. | ✔️ | ✔️ |
| Update Schema | Update a subject schema definition. | ✔️ | ✔️ |
| Validate Schema | Validate a schema definition. | ✔️ | ✔️ |
| Visual Schema Diff | Compare two versions of a subject schema and see a visual diff result. | ✔️ | ✔️ |
| Change Schema Compatibility Mode | Update the schema compatibility mode in one click. | ✔️ | ✔️ |
Kafka Connect
Manage ingress and egress of data with Kafka Connect.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Connector and Task Summary | At a glance information about all connectors, sinks, sources and tasks in your Connect Cluster. | ✔️ | ✔️ |
| Visualise Connectors | Charting for connector state, consumption, and production. | ✔️ | ✔️ |
| Connect Metrics | In-depth information on every connector, Task and associated consumer group. | ✔️ | ✔️ |
| Create Connectors | Start new connectors of any type known to your Connect Cluster. | ✔️ | ✔️ |
| Pause Connectors | Temporarily stop a connector from running. | ✔️ | ✔️ |
| Restart Connectors | Restart a paused connector. | ✔️ | ✔️ |
| Delete Connectors | Delete a connector. | ✔️ | ✔️ |
| View Connector Config | View the configuration of a connector. | ✔️ | ✔️ |
| Restart Task | Restart a connector task. | ✔️ | ✔️ |
| View Task Config | View the configuration of your tasks. | ✔️ | ✔️ |
| View Task Stacktrace | See error information about tasks. | ✔️ | ✔️ |
Multiple Resource Management
Integrate multiple clusters, registries, and connect installations with a single instance of kPow.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Multi-Cluster | Configure and manage multiple Kafka Clusters with a single kPow instance. | ✔️ | |
| Multi-Schema | Configure multiple Schema Registries with each connected Kafka Cluster (HA deployments). | ✔️ | |
| Multi-Connect | Configure multiple Connect Clusters with each connected Kafka Cluster (HA deployments). | ✔️ | |
| Multi-Tenancy | Restrict visibility of connected resources (cluster, connect, schema, topic, group, and stream) by User Role. | ✔️ |
Data
The fastest, simplest, smartest search available for Apache Kafka.
Data Inspect
When you need to find the needle in a haystack use kPow and kJQ.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Ultrafast Search | Read and search 100k+ messages in a single query. | ✔️ | ✔️ |
| Standard Serdes | All standard Kafka serdes supported out-of-the-box including JSON, Avro, Protobuf, JSON Schema, String, Integer, Long, Short. | ✔️ | ✔️ |
| Custom Serdes | Define your own custom serdes, e.g. Protobuf without Schema Registry integration. | ✔️ | ✔️ |
| Clojure Serdes | First class support for EDN, Transit, Transit-JSON, and Transit-MessagePack data. | ✔️ | ✔️ |
| Default Serdes | Set the default serdes presented to your users. | ✔️ | ✔️ |
| Schema Registry Integration | Built-in Schema Registry integration. | ✔️ | ✔️ |
| kJQ Filters | In-app JQ implementation to search and filter messages based on header, key or message value. | ✔️ | ✔️ |
| Multi-Topic Search | Search and filter messages from multiple topics at once. | ✔️ | ✔️ |
| Multi-Topic Regex | Search multiple-topics at once by regex discriminator. | ✔️ | ✔️ |
| Group Search | View the message consumed by consumer group assifgnments. | ✔️ | ✔️ |
| Time Search | Search from the first message, at a point in time, at a particular offset, or a specific topic partition. | ✔️ | ✔️ |
| Recent Search | Search an even distribution of messages from the end of your selected topics. | ✔️ | ✔️ |
| Search By Key | Extremely efficient searching by exact key match. | ✔️ | ✔️ |
| Share Search | Copy a link containing your search criteria to share with team members. | ✔️ | ✔️ |
| Copy to Clipboard | Quickly grab search results. | ✔️ | ✔️ |
| Export Results | Download search results as JSON or EDN. | ✔️ | ✔️ |
| Streaming Search | Search 1M+ messages in a single click. | ✔️ | ✔️ |
Data Produce
Perfect for sidelining messages to a Dead Letter Queue.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Produce Message | Write messages to any Kafka topic. | ✔️ | ✔️ |
| Reproduce Message | Quick option to reproduce the result of a Data Inspect search to the same, or a new topic. | ✔️ | ✔️ |
| Alter / Edit Message | Produce a new message that is the result of editing an existing message. | ✔️ | ✔️ |
| Serdes | Supports all serdes made available in Data Inspect. | ✔️ | ✔️ |
Governance and Data Management
Built for the enterprise, kPow serialises user interactions and masks private data.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Data Masking | Configurable masking of private data (PII, etc). | ✔️ | |
| Audit Log | All user interactions recorded in serialized, searchable Audit Log. | ✔️ | ✔️ |
| Export | All metrics and offsets available via Prometheus endpoints for integration with enterprise Alerting and Monitoring. | ✔️ | ✔️ |
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Consume | Read messages from any topic with the power of Data Inspect into the kREPL. | ✔️ | ✔️ |
| kJQ | Evaluate data in the kREPL with a subset of JQ. | ✔️ | ✔️ |
| Clojure | Evaluate data in the kREPL with a subset of Clojure. | ✔️ | ✔️ |
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Consumer Groups | Live topology visualisation of consumer groups with the ability to manage group offsets. | ✔️ | ✔️ |
| Streams | Live topology visualisation of Kafka Stream applications to a function level and RockDB metrics. | ✔️ | ✔️ |
Metrics, Alerting and Integrations
kPow integrates with Enterprise Alerting and Monitoring.
Metrics
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Charts | Rich, configurable charting of multiple metrics types for brokers, topics, groups, and streams. | ✔️ | ✔️ |
| Export | All metrics available via Prometheus endpoints for integration with enterprise alerting and monitoring tools. | ✔️ | ✔️ |
| Air Gapped | All telemetry stored in internal Kafka topics in your cluster. | ✔️ | ✔️ |
| Time Machine (coming soon) | Navigate to any point in time held in your internal kPow topics. | ✔️ |
Alerting
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Prometheus | All telemetry exposed in OpenMetrics format via Prometheus endpoints for integration with enterprise alerting and monitoring tools. | ✔️ | ✔️ |
Integrations
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Prometheus | All metrics exposed via Prometheus endpoints. | ✔️ | ✔️ |
| Slack | Send audit log items to the slack channel of your choice. | ✔️ | ✔️ |
| Authentication | Integration with LDAP, SAML, Okta, OpenID, and basic authentication providers. | ✔️ | ✔️ |
| Scripting (coming soon) | Control kPow via API and integrate with your CI/CD process. | ✔️ | ✔️ |
Security
User Authentication, Authorization, and more.
User Authentication
Integrations with standard Enterprise authentication providers.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Jetty (File, LDAP, DB, etc) | Standard JAAS authentication options provided by Jetty including LDAP, File, DB, and custom providers. | ✔️ | |
| SAML | Integrate kPow with your Enterprise SAML authentication provider. | ✔️ | |
| OpenID and OAuth 2.0 Authentication | kPow supports integration with Okta (OpenID) and Github (OAuth 2.0) SSO providers. | ✔️ |
User Authorization
Role Base Access Control for fine-grained control of user actions.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Simple | Apply global access controls to all users of kPow. | ✔️ | |
| RBAC | Configure Role Based Access Controls for fine-grained control of user actions. | ✔️ | |
| Temporary Policies | Provide time-limited escalation of user access to specific user roles. | ✔️ | |
| Staged Mutations | Simple workflow requiring admin consent to changes to your Kafka resources. | ✔️ | |
| Multi-Tenancy | Restrict visibility of connected resources (cluster, connect, schema, topic, group, and stream) by User Role. | ✔️ |
General Security
Data Masking, Audit Log, and more.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Data Masking | Configurable redaction of PII data from Data Inspect results. | ✔️ | ✔️ |
| Audit Log | All user actions serialised in an Audit Log topic. | ✔️ | ✔️ |
| HTTPS | HTTPS support out of the box. | ✔️ | ✔️ |
| kPow Admin | Admin roles with increased capabilities for controlling user actions. | ✔️ | ✔️ |
| Air Gapped Deployments | All kPow data stored in internal topics within your organisation. | ✔️ | ✔️ |
Deployment, Compatibility and Support
On-Premise, Cloud, kPow is built for air-gapped environments.
Deployment
We built kPow to make the developer experience with Kafka simple and enjoyable, and to save businesses time and money while growing their Kafka expertise.
| Feature | Description | Trial | Paid |
|---|---|---|---|
| On-Premises | Suitable for deployment on premises with vanilla Apache Kafka clusters. | ✔️ | ✔️ |
| Cloud | Built for the cloud and easily deployed within AWS/ECS/Fargate, Azure, GCP. | ✔️ | ✔️ |
| Marketplace | Available to purchase on the AWS Marketplace and Red Hat Marketplace. | ✔️ | ✔️ |
| Docker | Provided as a single docker container that runs with 2GB heap. | ✔️ | ✔️ |
| JAR | Available as a simple JAR file (including specific JAR for Java 8 deployments). | ✔️ | ✔️ |
Compatibility
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Apache 1.0+ | Built and tested with Apache Kafka. | ✔️ | ✔️ |
| Azure Event Hubs | Compatible with Azure Event Hubs. | ✔️ | ✔️ |
| Amazon MSK | Compatible with Amazon MSK. | ✔️ | ✔️ |
| Instaclustr | Compatible with Instaclustr Managed Platform. | ✔️ | ✔️ |
| RedPanda | Compatible with Red Panda. Where Red Panda diverges from Kafka you may observe reduced function or performance. | ✔️ | ✔️ |
| Confluent Cloud | Compatible with Confluent Cloud and provides further integrations for active client and disk metrics. | ✔️ | ✔️ |
| Aiven | Compatible with Aiven Kafka. | ✔️ | ✔️ |
| AMQ Streams | Compatible with Red Hat AMQ Streams. | ✔️ | ✔️ |
Support
| Feature | Description | Trial | Paid |
|---|---|---|---|
| Slack | Join our engineering slack to get immediate access to the kPow team. | ✔️ | |
| Email / Ticket | Raise a support ticket via email. | ✔️ | ✔️ |
| Video Support | Schedule a video call for training purposes or for help installing kPow. | ✔️ | ✔️ |
| Premium Support Packages | Available to support enterprises who prefer support SLA. | ✔️ |