Learn How to GitOps with Apache Kafka! — Register hereArrow right icon
Conduktor Console

Conduktor Console

Optimizes developer productivity through improving their speed of delivery and reducing time spent debugging issues

pattern

Visibility into Kafka

Get full visibility into what is happening in your Kafka ecosystem right now, and what has happened in the past. Enable rapid application development and a fast feedback loop for your developers.

product image
Message Viewer

View your topic messages, headers and metadata with full SerDe support for all primitive and basic data types, Avro, Protobuf, and JSON schema message formats.

Search, Sort & Filter

Find messages easily by searching the key, value, headers, and all associated metadata.

View Schemas & Compare Versions

Check the shape of your data, what has changed between schema versions, and how it's impacting your consuming applications. Full support for Avro, Protobuf and JSON message formats.

Data Export

Export data to share it with a colleague, attach it to a ticket, or run a deeper analysis.

pattern

Perform Kafka Operations

Kafka comes with a multitude of APIs, CLIs and many features to operate. Get all of these operations concentrated into a single interface and avoid unnecessary context switching.

product image
Automatic Connector Restarts

Deploy and manage connectors through Conduktor. Use the automatic connector restart functionality in case a failure is detected.

Manage & Validate Schemas

Manage Confluent-like and AWS Glue Schema Registry. Evolve your schemas and check the compatibility of changes.

Produce Data

Produce individual or streams of messages directly into your Kafka topics. Understand how your applications behave, no matter what you throw at them.

DLQ Management

Reinject messages from your dead-letter queue into the target topic with just a few clicks.

Service Account Management

Manage application credentials inside Conduktor.

pattern

Monitor Your Kafka Applications

While there are many solutions for monitoring Kafka, few come with an opinionated solution and clear guidance on what matters most. Monitoring Kafka should not just be for Ops, but also for product teams that are responsible for their applications.

product image
Consumer Lag

Monitor if your applications are lagging and whether messages are being processed in a timely manner.

Topic Alerting

Detect irregular or absence of messages in critical business and Kafka connect sink topics.

Cluster Health Check

Monitoring of key Kafka metrics such as Under-Replicated Partitions, Active Controllers, Min In-Sync-Replicas, Unclean Elections and Offline Partitions.

Infrastructure Alerting

Detect Kafka infrastructure and application irregularities and get real-time alerting via Slack or MS Teams.

pattern

Application Resilience

We know Kafka is resilient, but what about your application? Test unforeseen and unclear paths for potential production incidents (that will happen at some point!).

product image
Chaos Engineering

An unknown or unforeseen failure in Kafka could take hours to track down and rectify (even for a seasoned expert!). Use chaos engineering to simulate unclear paths to validate application resilience.

Chaos configurations
Checkmark

Simulate Broken Brokers

Checkmark

Duplicate Messages On Produce/Fetch

Checkmark

Simulate Invalid Schema Id

Checkmark

Simulate Leader Elections Errors

Checkmark

Simulate Message Corruption

Checkmark

Simulate Slow Broker

Checkmark

Simulate Slow Producers & Consumers

Checkmark

Simulate Latency On Every Kafka Interaction

pattern

Integrated with your existing stack

Conduktor enables multi-cluster connections and supports all Kafka providers, both cloud and on-premise. Bring your source of truth of users and groups from your existing identity provider (SSO) and integrate with messaging tools for enhanced notifications and alerts.

product image
Any Kafka Provider

Conduktor is compatible with any Kafka provider: Apache Kafka, Confluent, AWS MSK, Aiven, Strimzi, Red Panda, self-managed, cloud, or hybrid.

Multi-Cluster Support

Embed multiple cluster connections to easily switch cluster context. Powerful for hybrid customers and those using multiple providers.

Notifications & Alerts

Integrate with messaging tools such as Slack and Microsoft Teams to receive built-in and custom alerts.

Schema Registry

Conduktor supports integration and management of Confluent-like and AWS Glue schema registry.

pattern

Security

Eliminate the risk of shadow IT and blanket access rules that slow down productivity and negatively impact incident resolution times. Conduktor brings extensive RBAC and data masking controls to ensure your developers can operate freely without compromising on enterprise security.

product image
Single-Sign-On (SSO)

Integrate with your IdP to bring your existing source of truth. Supports LDAP, Active Directory and OpenId Connect (Azure AD, Ping Identity, Auth0, Okta, OneLogin, AWS Cognito, Google Cloud Identity)

Permissions

Manage access and permissions to Conduktor and Kafka resources for users and groups. Define granular permissions on Kafka resources such as clusters, consumer groups, topics, subjects and connectors.

External Groups Sync

Synchronize with your existing IdP/LDAP to set permissions on your existing groups and avoid discrepancies.

Schema Registry

Conduktor supports integration and management of Confluent-like and AWS Glue schema registry.

Multi-Cluster Auth

Have a unified RBAC model enveloping all your existing Kafka clusters, regardless of their provider.

Kafka ACLs Management

View and manage Kafka ACLs to control authorization for your clusters data.

Data Masking Policies

Mask sensitive and personal data inside the interface at both a topic and field-level granularity for individual users and groups.

Audit Trail

Everything your Users and your Applications are doing with Kafka is now monitored and logged. You have an interface to navigate and filter through time, events and resources being accessed.

Deployments

Conduktor can be deployed on-premise in various ways including air-gapped environments.

One interface for all of your Kafka operations, troubleshooting and data exploration needs

Supports multiple
cluster connection
SerDe Support
Checkmark AVRO
Checkmark Protobuf
Checkmark JSON Schema
Checkmark JSON (without Schema)
Works with any Kafka

Compatible with any Kafka provider (Apache Kafka, Confluent, AWS MSK, Aiven, Strimzi, etc...), self-managed, cloud, hybrid.

Kafka IntegrationAWS IntegrationGCP IntegrationConfluent IntegrationAiven IntegrationAzure IntegrationRedpanda IntegrationStrimzi Integration
Authentication

Azure AD, Ping Identity, Auth0, Okta, OneLogin, AWS Cognito, Google Cloud Identity, AWS IAM Authentication

AzurePingIdentityAuth0OktaOneLoginCloudIdentityAWS
Schema Registry
Checkmark Confluent-like
Checkmark AWS Glue Deserializer
Checkmark AWS Glue Schema CRUD
Notifications & Alerts
SlackMicrosoft Teams
Certificate management
CRTPEMJKSP12
Supports
Checkmark PLAIN
Checkmark SSL
Checkmark AWS IAM
Checkmark SASL (SCRAM, OAUTHBEARER, GSSAPI)
Permissions

Granular permission management per user/group.
Permissions on Kafka resources:

Checkmark Cluster
Checkmark Consumer Group
Checkmark Topic
Checkmark Subject
Checkmark Connector
Audit log for users and applications
Kafka ACLs management
Data Obfuscation /
Masking in the interface
Checkmark Topic level, field level
Checkmark For user, for group
Auto-logout after inactivity /
Max session timeout
Resource (topic)
tagging/add metadata
Topic Mangement
Checkmark Create topic
Checkmark Configure topic
Checkmark Add Partitions
Checkmark Delete
Checkmark Empty
Service Account
Management
Produce data
Checkmark Single message
Checkmark Flow (stream of messages)
Checkmark Randomize data based on schema definition
Checkmark Apply headers
Checkmark With compression
Checkmark Reinject data
Consume messages
Checkmark Filter per partitions/offsets
Checkmark Filter from a given date/offset (including consumer group's current position)
CheckmarkAdvanced filtering capabilities (JS Filters)
Checkmark Restrict fields needed during investigations (JQ)
Checkmark Save templates (filters)
Topic Mangement
Checkmark CRUD operations on Schemas
Checkmark Test compatibility
Checkmark Version diffs
Connector Management
Checkmark See status/restart connectors
Checkmark Configure Automatic
Checkmark Connector Restart strategy
Reset offset

(skip poison pills)

Consumer Lag
Live updating
time-series graphs
Graph
MonitoringCluster health

URP, Offline Partitions, < Min ISR, Unclean Elections, Active Controller Count

Topic throughput/storage
Simulate Broken
Brokers
Simulate Latency On Every
Kafka Interaction
Simulate Invalid
Schema Id
Simulate Leader
Elections Errors
Simulate Slow
Broker
Simulate Message
Corruption
Simulate Slow
Producers & Consumers
Duplicate Messages On
Produce/Fetch
DockerAvailable as a
Docker imageer
KubernetesKubernetes
Helm Charts
Air-Gapped DeploymentsAir-Gapped
Deployments