v5.0
Latest
5.0
4.3
4.2
4.1
4.0
3.2
3.1
3.0
2.3
2.2
2.1
2.0
1.1
1.0
Documentation
Help Center
Lenses.io
v5.0
Latest
5.0
4.3
4.2
4.1
4.0
3.2
3.1
3.0
2.3
2.2
2.1
2.0
1.1
1.0
Prerequisites
Installation
Linux
Docker
Kubernetes
Helm
Persistent volumes
Role based access
Clouds
AWS MSK
Azure HDInsight
Install with Azure Marketplace
Networking
Google
IBM
Aiven
Service discovery
Configuration
Static configuration
Persistent Storage
JVM options
Plugins
SQL Streaming
SQL In Process
SQL on Connect
SQL on Kubernetes
Exposing metrics
Logs
HTTPS & TLS
Load balancing & proxies
Kafka ACLs
Options reference
Basics
Persistent Storage
Schema Registries
Deployments
SQL
Kafka topics
Security
Advanced
Topology
Admin permissions
Data permissions
Application permissions
External applications
Dynamic configuration
License
Kafka
Lenses Setup Wizard
Schema Registry
Zookeeper
Kafka Connect
Kerberos
Services metrics
SSL/TLS Configuration
Integrations
Authentication
Basic auth
Lenses administrator
LDAP
Azure AD
Single Sign On / SAML
Azure
Google
Keycloak
Okta
OneLogin
Keystore
FAQ
Kerberos
Custom HTTP
Monitoring
Alerts
Audits
Data sources
Kafka Connect
Stream Reactor
Install
Sources
AWS S3
Cassandra
FTP
Hive
JMS
MQTT
Pulsar
Source record converters
Sinks
Azure CosmosDB
AWS S3
Cassandra
Elastic
Hazelcast
HBase
Hive
InfluxDB
JMS
Kudu
MongoDB
MQTT
Pulsar
Redis
Payload support
Error policies
Dockers
Helm charts
Quickstart docker compose
Secrets
AWS Secret Manager
Azure Keyvault
Hashicorp Vault
Environment
AES-256 Decryption
Other applications
Connect CLI
Adding Connectors to the topology
Release notes
Lenses SQL
Snapshot mode
Quick start
Insert and delete data
Manage running queries
Manage Kafka topics
Meta Fields
Views and synonyms
How-To
Tuning
Streaming mode
Prerequisites
Concepts
Projections
Joins
Lateral Joins
Aggregations
Time and windows
Set storage format
Settings
Expressions
Functions
Storage formats
Plugins
User defined functions
User defined aggregation functions
Deserializers
Nullability
Tools
CLI
Provisioning Lenses
Construct provision.yaml
Is CLI provision suitable for GitOps?
Admin
Users
Groups
Service Accounts
Connections
Alert settings
Schemas
Alert channels
Audits
Audit channels
Lenses Config
Lenses Logs
License
Data
Kafka topics
Datasets
Elasticsearch
Data polices
Querying Kafka topics
Applications
SQL Processors
Kafka Connect
Manage Kafka
Kafka ACLs
Kafka quotas
Kafka consumers
GitOps
Importing
Exporting
API
Dev Box
Examples
FAQ
Client SDKs
Registering applications
Java topology SDK
Building your application topology
Java metrics SDK
Kafka Stream metrics
Akka Streams metrics
Spark metrics
Rest HTTP registration
Golang client
Python client
Querying topic data
Working with topics
MSK portal
Multi cluster
Release notes
5.0.1 release
5.0.2 release
5.0.3 release
5.0.4 release
5.0.5 release
5.0.6 release
5.0.7 release
Helm release notes
Snapshot Engine
Upgrade notes
5.0
Prerequisites
Installation
Linux
Docker
Kubernetes
Helm
Persistent volumes
Role based access
Clouds
AWS MSK
Azure HDInsight
Install with Azure Marketplace
Networking
Google
IBM
Aiven
Service discovery
Configuration
Static configuration
Persistent Storage
JVM options
Plugins
SQL Streaming
SQL In Process
SQL on Connect
SQL on Kubernetes
Exposing metrics
Logs
HTTPS & TLS
Load balancing & proxies
Kafka ACLs
Options reference
Basics
Persistent Storage
Schema Registries
Deployments
SQL
Kafka topics
Security
Advanced
Topology
Admin permissions
Data permissions
Application permissions
External applications
Dynamic configuration
License
Kafka
Lenses Setup Wizard
Schema Registry
Zookeeper
Kafka Connect
Kerberos
Services metrics
SSL/TLS Configuration
Integrations
Authentication
Basic auth
Lenses administrator
LDAP
Azure AD
Single Sign On / SAML
Azure
Google
Keycloak
Okta
OneLogin
Keystore
FAQ
Kerberos
Custom HTTP
Monitoring
Alerts
Audits
Data sources
Kafka Connect
Stream Reactor
Install
Sources
AWS S3
Cassandra
FTP
Hive
JMS
MQTT
Pulsar
Source record converters
Sinks
Azure CosmosDB
AWS S3
Cassandra
Elastic
Hazelcast
HBase
Hive
InfluxDB
JMS
Kudu
MongoDB
MQTT
Pulsar
Redis
Payload support
Error policies
Dockers
Helm charts
Quickstart docker compose
Secrets
AWS Secret Manager
Azure Keyvault
Hashicorp Vault
Environment
AES-256 Decryption
Other applications
Connect CLI
Adding Connectors to the topology
Release notes
Lenses SQL
Snapshot mode
Quick start
Insert and delete data
Manage running queries
Manage Kafka topics
Meta Fields
Views and synonyms
How-To
Tuning
Streaming mode
Prerequisites
Concepts
Projections
Joins
Lateral Joins
Aggregations
Time and windows
Set storage format
Settings
Expressions
Functions
Storage formats
Plugins
User defined functions
User defined aggregation functions
Deserializers
Nullability
Tools
CLI
Provisioning Lenses
Construct provision.yaml
Is CLI provision suitable for GitOps?
Admin
Users
Groups
Service Accounts
Connections
Alert settings
Schemas
Alert channels
Audits
Audit channels
Lenses Config
Lenses Logs
License
Data
Kafka topics
Datasets
Elasticsearch
Data polices
Querying Kafka topics
Applications
SQL Processors
Kafka Connect
Manage Kafka
Kafka ACLs
Kafka quotas
Kafka consumers
GitOps
Importing
Exporting
API
Dev Box
Examples
FAQ
Client SDKs
Registering applications
Java topology SDK
Building your application topology
Java metrics SDK
Kafka Stream metrics
Akka Streams metrics
Spark metrics
Rest HTTP registration
Golang client
Python client
Querying topic data
Working with topics
MSK portal
Multi cluster
Release notes
5.0.1 release
5.0.2 release
5.0.3 release
5.0.4 release
5.0.5 release
5.0.6 release
5.0.7 release
Helm release notes
Snapshot Engine
Upgrade notes
Chat on Slack
Data
Data operations with the CLI.
Contents
Kafka topics
Datasets
Elasticsearch
Data polices
Querying Kafka topics
