Use kPow to monitor and control all of your Kafka resources.
All the topic information you need, from leader disk to under-replicated partitions.
Feature | Description |
---|---|
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. |
Multi-dimensional insight into consumer activity in your clusters.
Feature | Description |
---|---|
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. |
Quickly identify unbalanced brokers and understand how your data is physically distributed.
Feature | Description |
---|---|
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. |
Secure your clusters with first class support for Kafka ACLs.
Feature | Description |
---|---|
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. |
kPow is built from standard Apache Kafka clients.
Feature | Description |
---|---|
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. |
Derived insights about your connected Kafka resources.
Feature | Description |
---|---|
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 |
---|---|
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. |
Make sense of schemas and subjects, from visual diffs to compatibility updates.
Feature | Description |
---|---|
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. |
Manage ingress and egress of data with Kafka Connect.
Feature | Description |
---|---|
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. |
Integrate multiple clusters, registries, and connect installations with a single instance of kPow.
Feature | Description |
---|---|
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. |
The fastest, simplest, smartest search available for Apache Kafka.
When you need to find the needle in a haystack use kPow and kJQ.
Feature | Description |
---|---|
Ultra Fast Search | Search and filter 100k+ messages in a single query. |
Streaming Search | Search and filter 1M+ messages in a single click. |
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. |
Perfect for sidelining messages to a Dead Letter Queue.
Feature | Description |
---|---|
Produce Message | Write messages to any Kafka topic. |
Produce Multiple Messages | Produce multiple messages at once to a single topic. |
Produce with Message Headers | Set (or edit existing) message headers. |
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. |
Built for the enterprise, kPow serialises user interactions and masks private data.
Feature | Description |
---|---|
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 |
---|---|
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 |
---|---|
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. |
kPow integrates with Enterprise Alerting and Monitoring.
Feature | Description |
---|---|
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. |
Feature | Description |
---|---|
Prometheus | All telemetry exposed in OpenMetrics format via Prometheus endpoints for integration with enterprise alerting and monitoring tools. |
Feature | Description |
---|---|
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. |
User Authentication, Authorization, and more.
Integrations with standard Enterprise authentication providers.
Feature | Description |
---|---|
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. |
Role Base Access Control for fine-grained control of user actions.
Feature | Description |
---|---|
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. |
Data Masking, Audit Log, and more.
Feature | Description |
---|---|
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. |
On-Premise, Cloud, kPow is built for air-gapped environments.
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 |
---|---|
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). |
Feature | Description |
---|---|
Apache 1.0+ | Built and tested with Apache Kafka. |
Amazon MSK | Compatible with Amazon MSK. |
Instaclustr | Compatible with Instaclustr Managed Platform. |
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. |
Feature | Description |
---|---|
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 help when initially installing kPow. |
Premium Support Packages | Available to support enterprises who prefer support SLA. |