LogoLogo
HomeProductsDownload Community Edition
6.0
  • Lenses DevX
  • Kafka Connectors
  • Kafka to Kafka Replicator
  • Overview
  • What's New?
    • Version 6.0.5
      • Features / Improvements & Fixes
    • Version 6.0.4
      • Features / Improvements & Fixes
    • Version 6.0.3
      • Features / Improvements & Fixes
    • Version 6.0.2
    • Version 6.0.1
    • Version 6.0.0-la.2
      • Features / Improvements & Fixes
    • Version 6.0.0-la.1
      • Features / Improvements & Fixes
    • Version 6.0.0-la.0
      • Features / Improvements & Fixes
    • Version 6.0.0-alpha.20
      • Features / Improvements & Fixes
      • Helm
    • Version 6.0.0-alpha.19
      • Features / Improvements & Fixes
      • Helm
    • Version 6.0.0-alpha.18
      • Features / Improvements & Fixes
      • Helm
    • Version 6.0.0-alpha.17
      • Features / Improvements & Fixes
      • Helm
    • Version 6.0.0-alpha.16
    • Version 6.0.0-alpha.14
  • Getting Started
    • Setting Up Community Edition
      • Hands-On Walk Through of Community Edition
    • Connecting Lenses to your Kafka environment
      • Overview
      • Install
  • Deployment
    • Installation
      • Kubernetes - Helm
        • Deploying HQ
        • Deploying an Agent
      • Docker
        • Deploying HQ
        • Deploying an Agent
      • Linux
        • Deploying HQ
        • Deploying an Agent
    • Configuration
      • Authentication
        • Admin Account
        • Basic Authentication
        • SSO & SAML
          • Overview
          • Azure SSO
          • Google SSO
          • Keycloak SSO
          • Okta SSO
          • OneLogin SSO
          • Generic SSO
      • HQ
        • Configuration Reference
      • Agent
        • Overview
        • Provisioning
          • Overview
          • HQ
          • Kafka
            • Apache Kafka
            • Aiven
            • AWS MSK
            • AWS MSK Serverless
            • Azure EventHubs
            • Azure HDInsight
            • Confluent Cloud
            • Confluent Platform
            • IBM Event Streams
          • Schema Registries
            • Overview
            • AWS Glue
            • Confluent
            • Apicurio
            • IBM Event Streams Registry
          • Kafka Connect
          • Zookeeper
          • AWS
          • Alert & Audit integrations
          • Infrastructure JMX Metrics
        • Hardware & OS
        • Memory & CPU
        • Database
        • TLS
        • Kafka ACLs
        • Rate Limiting
        • JMX Metrics
        • JVM Options
        • SQL Processor Deployment
        • Logs
        • Plugins
        • Configuration Reference
  • User Guide
    • Environments
      • Create New Environment
    • Lenses Resource Names (LRNs)
    • Identity & Access Management
      • Overview
      • Users
      • Groups
      • Roles
      • Service Accounts
      • IAM Reference
      • Example Policies
    • Topics
      • Global Topic Catalogue
      • Environment Topic Catalogue
        • Finding topics & fields
        • Searching for messages
        • Inserting & deleting messages
        • Viewing topic metrics
        • Viewing topic partitions
        • Topic Settings
        • Adding metadata & tags to topics
        • Managing topic configurations
        • Approval requests
        • Downloading messages
        • Backup & Restore
    • SQL Studio
      • Concepts
      • Best practices
      • Filter by timestamp or offset
      • Creating & deleting Kafka topics
      • Filtering
      • Limit & Sampling
      • Joins
      • Inserting & deleting data
      • Aggregations
      • Metadata fields
      • Views & synonyms
      • Arrays
      • Managing queries
    • Applications
      • Connectors
        • Overview
        • Sources
        • Sinks
        • Secret Providers
      • SQL Processors
        • Concepts
        • Projections
        • Joins
        • Lateral Joins
        • Aggregations
        • Time & Windows
        • Storage format
        • Nullibility
        • Settings
      • External Applications
        • Registering via SDK
        • Registering via REST
    • Schemas
    • Monitoring & Alerting
      • Infrastructure Health
      • Alerting
        • Alert Reference
      • Integrations
      • Consumer Groups
    • Self Service & Governance
      • Data policies
      • Audits
      • Kafka ACLs
      • Kafka Quotas
    • Topology
    • Tutorials
      • SQL Processors
        • Data formats
          • Changing data formats
          • Rekeying data
          • Controlling AVRO record names and namespaces
          • Changing the shape of data
        • Filtering & Joins
          • Filtering data
          • Enriching data streams
          • Joining streams of data
          • Using multiple topics
        • Aggregations
          • Aggregating data in a table
          • Aggregating streams
          • Time window aggregations
        • Complex types
          • Unwrapping complex types
          • Working with Arrays
        • Controlling event time
      • SQL Studio
        • Querying data
        • Accessing headers
        • Deleting data from compacted topics
        • Working with JSON
    • SQL Reference
      • Expressions
      • Functions
        • Aggregate
          • AVG
          • BOTTOMK
          • COLLECT
          • COLLECT_UNIQUE
          • COUNT
          • FIRST
          • LAST
          • MAXK
          • MAXK_UNIQUE
          • MINK
          • MINK_UNIQUE
          • SUM
          • TOPK
        • Array
          • ELEMENT_OF
          • FLATTEN
          • IN_ARRAY
          • REPEAT
          • SIZEOF
          • ZIP_ALL
          • ZIP
        • Conditions
        • Conversion
        • Date & Time
          • CONVERT_DATETIME
          • DATE
          • DATETIME
          • EXTRACT_TIME
          • EXTRACT_DATE
          • FORMAT_DATE
          • FORMAT_TIME
          • FORMAT_TIMESTAMP
          • HOUR
          • MONTH_TEXT
          • MINUTE
          • MONTH
          • PARSE_DATE
          • PARSE_TIME_MILLIS
          • PARSE_TIME_MICROS
          • PARSE_TIMESTAMP_MILLIS
          • PARSE_TIMESTAMP_MICROS
          • SECOND
          • TIMESTAMP
          • TIME_MICROS
          • TIMESTAMP_MICROS
          • TIME_MILLIS
          • TIMESTAMP_MILLIS
          • TO_DATE
          • TO_DATETIME
          • TOMORROW
          • TO_TIMESTAMP
          • YEAR
          • YESTERDAY
        • Headers
          • HEADERASSTRING
          • HEADERASINT
          • HEADERASLONG
          • HEADERASDOUBLE
          • HEADERASFLOAT
          • HEADERKEYS
        • JSON
          • JSON_EXTRACT_FIRST
          • JSON_EXTRACT_ALL
        • Numeric
          • ABS
          • ACOS
          • ASIN
          • ATAN
          • CBRT
          • CEIL
          • COSH
          • COS
          • DEGREES
          • DISTANCE
          • FLOOR
          • MAX
          • MIN
          • MOD
          • NEG
          • POW
          • RADIANS
          • RANDINT
          • ROUND
          • SIGN
          • SINH
          • SIN
          • SQRT
          • TANH
          • TAN
        • Nulls
          • ISNULL
          • ISNOTNULL
          • COALESCE
          • AS_NULLABLE
          • AS_NON_NULLABLE
        • Obfuscation
          • ANONYMIZE
          • MASK
          • EMAIL
          • FIRST1
          • FIRST2
          • FIRST3
          • FIRST4
          • LAST1
          • LAST2
          • LAST3
          • LAST4
          • INITIALS
        • Offsets
        • Schema
          • TYPEOF
          • DUMP
        • String
          • ABBREVIATE
          • BASE64
          • CAPITALIZE
          • CENTER
          • CHOP
          • CONCAT
          • CONTAINS
          • DECODE64
          • DELETEWHITESPACE
          • DIGITS
          • DROPLEFT
          • DROPRIGHT
          • ENDSWITH
          • INDEXOF
          • LEN
          • LOWER
          • LPAD
          • MKSTRING
          • REGEXP
          • REGEX_MATCHES
          • REPLACE
          • REVERSE
          • RPAD
          • STARTSWITH
          • STRIPACCENTS
          • SUBSTR
          • SWAPCASE
          • TAKELEFT
          • TAKERIGHT
          • TRIM
          • TRUNCATE
          • UNCAPITALIZE
          • UPPER
          • UUID
        • User Defined Functions
        • User Defined Aggregate Functions
      • Deserializers
      • Supported data formats
        • Protobuf
  • Resources
    • Downloads
    • CLI
      • Environment Creation
    • API Reference
      • API Authentication
      • Websocket Spec
      • Lenses API Spec
        • Authentication
        • Environments
        • Users
        • Groups
        • Roles
        • Service Accounts
        • Meta
        • Settings
        • License
        • Topics
        • Applications
          • SQL Processors
          • Kafka Connectors
          • External Applications
        • Kafka ACLs & Quotas
        • Kafka Consumer Groups
        • Schema Registry
        • SQL Query Management
        • Data Policies
        • Alert Channels
        • Audit Channels
        • Provisioning State
        • Agent Metadata
        • Backup & Restore
        • As Code
Powered by GitBook
LogoLogo

Resources

  • Privacy
  • Cookies
  • Terms & Conditions
  • Community EULA

2024 © Lenses.io Ltd. Apache, Apache Kafka, Kafka and associated open source project names are trademarks of the Apache Software Foundation.

On this page
  • Administration
  • Applications
  • Alerts
  • Audits
  • Data Policies
  • Environments
  • Governance
  • IAM
  • Kafka Connect
  • Kafka
  • Kubernetes
  • Registry
  • Schemas
  • SQL Streaming

Was this helpful?

Export as PDF
  1. User Guide
  2. Identity & Access Management

IAM Reference

This page describes the IAM Reference options.

Administration

service: administration

Resource Syntax

  • administration:connection:${Environment}/${ConnectionType}/${Connection}

  • administration:license:${Environment}

  • administration:lenses-logs:${Environment}

  • administration:lenses-configuration:${Environment}

  • administration:setting:${Setting}

Operation
Resource Type
Description

CreateConnection

connection

ListConnections

connection

GetConnectionDetails

connection

UpdateConnection

connection

DeleteConnection

connection

ListLicenses

license

GetLicenseDetails

license

UpdateLicense

license

GetLensesLogs

lenses-logs

GetLensesConfiguration

lenses-configuration

ListAgents

agent

GetAgentDetails

agent

UpdateAgent

agent

DeleteAgent

agent

GetSetting

setting

UpdateSetting

setting

Applications

service: applications

Resource Syntax

Operation
Resource Type
Description

RegisterApplication

external-application

UnregisterApplication

external-application

ListApplications

external-application

GetApplicationDetails

external-application

ListApplicationDependants

external-application

Alerts

service: alerts

Resource Syntax

  • alerts:alert:${Environment}/${AlertType}/${Alert}

  • alerts:rule:${Environment}/Infrastructure/KafkaBrokerDown

  • alerts:rule:${Environment}/DataProduced/red-app-going-slow

Operation
Resource Type
Description

CreateAlertRule

rule

DeleteAlertRule

rule

UpdateAlertRule

rule

ListAlertRules

rule

GetAlertRuleDetails

rule

ToggleAlertRule

rule

ListAlertEvents

alert-event

DeleteAlertEvents

alert-event

CreateChannel

alert-channel

ListChannels

alert-channel

GetChannelDetails

alert-channel

UpdateChannel

alert-channel

DeleteChannel

alert-channel

Audits

service: audit

Resource Syntax

  • audit:log:${Environment}

  • audit:channel:${Environment}/${AuditChannelType}/${AuditChannel}

Operation
Resource Type
Description

ListLogEvents

log

GetLogEventDetails

log

CreateChannel

channel

ListChannels

channel

GetChannelDetails

channel

UpdateChannel

channel

DeleteChannel

channel

ToggleChannel

channel

Data Policies

service: data-policies

Resource Syntax

  • data-policies:policy:${Environment}/${Policy}

Operation
Resource Type
Description

CreatePolicy

policy

ListPolicies

policy

GetPolicyDetails

policy

UpdatePolicy

policy

DeletePolicy

policy

ListPolicyDependants

policy

Environments

service: environments

Resource Syntax

  • environments:environment:${Environment}

Operation
Resource Type
Description

CreateEnvironment

environment

DeleteEvironment

environment

ListEnvironments

environment

UpdateEnvironment

environment

AccessEnvironment

environment

Governance

service: governance

Resource Syntax

  • governance:request:${Environment}/${ActionType}/*

  • governance:rule:${Environment}/${RuleCategory}/*

Operation
Resource Type
Description

CreateRequest

request

ListRequests

request

GetRequestDetails

request

ApproveRequest

request

DenyRequest

request

GetRuleDetails

rule

UpdateRule

rule

IAM

service: iam

Resource Syntax

  • iam:role:${Role}

  • iam:group:${Group}

  • iam:user:${Username}

  • iam:service-account:${ServiceAccount}

Operation
Resource Type
Description

CreateRole

role

DeleteRole

role

UpdateRole

role

ListRoles

role

ListRoleDependants

role

GetRoleDetails

role

CreateGroup

group

DeleteGroup

group

UpdateGroup

group

ListGroups

group

ListGroupDependants

group

GetGroupDetails

group

CreateUser

user

DeleteUser

user

UpdateUser

user

ListUsers

user

ListUserDependants

user

GetUserDetails

user

CreateServiceAccount

service account

DeleteServiceAccount

service account

UpdateServiceAccount

service account

ListServiceAccounts

service account

ListServiceAccountDependants

service account

GetServiceAccountDetails

service account

Kafka Connect

service: kafka-connect

Resource Syntax

  • kafka-connect:connector:${Environment}/${KafkaConnectCluster}/${Connector}

  • kafka-connect:cluster:${Environment}/${KafkaConnectCluster}

Example role permission
name: global-connector-operator
policy:
  - action:
      - iam:List*
      - iam:Get*
    resource: iam:*
    effect: allow
  - action:
      - environments:Get*
      - environments:List*
      - environments:AccessEnvironment
    resource: environments:*
    effect: allow
  - action:
      - kafka-connect:List*
      - kafka-connect:GetClusterDetails
      - kafka-connect:GetConnectorDetails
      - kafka-connect:StartConnector
      - kafka-connect:StopConnector
    resource:
      - kafka-connect:cluster:*/*
      - kafka-connect:connector:*/*/*
    effect: allow
Operation
Resource Type
Description

CreateConnector

connector

ListConnectors

connector

ListConnectors

connector

GetConnectorConfiguration

connector

UpdateConnectorConfiguration

connector

DeleteConnector

connector

StartConnector

connector

StopConnector

connector

ListConnectorDependants

connector

ListClusters

cluster

GetClusterDetails

cluster

DeployConnectors

cluster

Kafka

service: kafka

Resource Syntax

  • kafka:topic:${Environment}/${KafkaCluster}/${Topic}

  • kafka:acl:${Environment}/${KafkaCluster}/${AclResourceType}/* or kafka:acl:${Environment}/${KafkaCluster}/${AclResourceType}/${PrincipalType}/${Principal}

  • kafka:quota:${Environment}/${KafkaCluster}/${QuotaType}/* or

  • kafka:quota:${Environment}/${KafkaCluster}/clients

  • kafka:quota:${Environment}/${KafkaCluster}/users-default

  • kafka:quota:${Environment}/${KafkaCluster}/client/${ClientID}

  • kafka:quota:${Environment}/${KafkaCluster}/user/${Username}

  • kafka:quota:${Environment}/${KafkaCluster}/user/${Username}/client/${ClientID}

  • kafka:quota:${Environment}/${KafkaCluster}/user-client/${Username}/${ClientID}

  • kafka:quota:${Environment}/${KafkaCluster}/user/${Username}/client/*

  • kafka:quota:${Environment}/${KafkaCluster}/user-all-clients/${Username}

Example role permission
name: example
policy:
  - action:
      - kafka:ListTopics
      - kafka:GetTopicDetails 
    resource: 
      - kafka:topic:my_env/kafka/my_topic
Operation
Resource Type
Description

CreateTopic

topic

DeleteTopic

topic

ListTopics

topic

GetTopicDetails

topic

UpdateTopicDetails

topic

ReadTopicData

topic

WriteTopicData

topic

DeleteTopicData

topic

ListTopicDependants

topic

List visibility of all entities that depend on this entity e.g. ListTopicDependants means that you'll be able to see (i.e. List) all consumer groups that read from that topic regardless of what your specific consumer group permissions.

CreateAcl

acl

GetAclDetails

acl

UpdateAcl

acl

DeleteAcl

acl

CreateQuota

quota

ListQuotas

quota

GetQuotaDetails

quota

UpdateQuota

quota

DeleteQuota

quota

DeleteConsumerGroup

consumer-group

UpdateConsumerGroup

consumer-group

ListConsumerGroups

consumer-group

GetConsumerGroupDetails

consumer-group

ListConsumerGroupDependants

consumer-group

Kubernetes

service: kubernetes

Resource Syntax

  • kubernetes:cluster:${Environment}/${KubernetesCluster}

  • kubernetes:namespace:${Environment}/${KubernetesCluster}/${KubernetesNamespace}

Operation
Resource Type
Description
Example

ListClusters

cluster

GetClusterDetails

cluster

ListNamespaces

namespace

DeployApps

namespace

Registry

service: registry

Resource Syntax

  • schemas:registry:${Environment}/${SchemaRegistry}

Operation
Resource Type
Description

GetRegistryConfiguration

registry

UpdateRegistryConfiguration

registry

Schemas

service: schemas

Resource Syntax

  • schemas:schema:${Environment}/${SchemaRegistry}/${Schema}

Operation
Resource Type
Description

CreateSchema

schema

DeleteSchema

schema

UpdateSchema

schema

GetSchemaDetails

schema

ListSchemas

schema

ListSchemaDependants

schema

SQL Streaming

service: sql-streaming

Resource Syntax

  • sql-streaming:sql-processor:${Environment}/${KubernetesCluster}/${KubernetesNamespace}/${SqlProcessor}

  • For IN_PROC processors sql-streaming:sql-processor:${Environment}/lenses-in-process/default/${SqlProcessor}

Available Actions
Resource Type
Description

CreateProcessor

sql-processor

ListProcessors

sql-processor

GetProcessorDetails

sql-processor

GetProcessorSql

sql-processor

UpdateProcessorSql

sql-processor

DeleteProcessor

sql-processor

StartProcessor

sql-processor

StopProcessor

sql-processor

ScaleProcessor

sql-processor

GetProcessorLogs

sql-processor

ListProcessorDependants

sql-processor

PreviousService AccountsNextExample Policies

Last updated 6 months ago

Was this helpful?