LogoLogo
HomeProductsDownload Community Edition
5.5
  • Lenses DevX
  • Kafka Connectors
  • Kafka to Kafka Replicator
  • Overview
  • Learn
  • What’s New?
  • Getting Started
    • Quick Start
    • Connecting Lenses to your environment
      • Prerequisites
      • Kafka
        • Apache Kafka
        • AWS MSK
        • AWS MSK Serverless
        • Aiven
        • Azure HDInsight
        • Confluent Cloud
        • Confluent Platform
        • IBM Event Streams
      • Adding a License
      • Kafka Connect
      • Schema Registries
        • AWS Glue
        • Confluent
        • Apicurio
        • IBM Event Streams Registry
      • Zookeeper
      • Alert & Audit Integrations
      • AWS
  • Deployment
    • Installation
      • Helm
      • Docker
      • Linux
      • AWS Marketplace
      • Lenses Box
      • Automating Connections
        • File Watcher Provisioning
        • API Provisioning
        • Provisioning examples
          • Kafka
          • Zookeeper
          • Schema Registry
          • Kafka Connect
          • Kerberos
          • JMX Metrics
        • Provisioning API reference
        • CLI Import & Export
    • Configuration
      • Identity & Access Management
        • Authentication
          • Admin Account
          • Azure AD
          • Basic Authentication
          • Custom Http
          • LDAP
          • SSO & SAML
            • Azure SSO
            • Google SSO
            • Keycloak SSO
            • Okta SSO
            • Onelogin SSO
            • FAQs
          • Kerberos
        • Groups
        • Users
        • Service accounts
        • Permission Reference
      • Lenses Metadata Database
      • Enable TLS on Lenses
      • Required Kafka ACLs
      • SQL Processor Deployment
      • Lenses JVM Options
      • Lenses JMX Metrics
      • Rate Limiting
      • Networking with Load Balancers
      • Logs
      • Plugins
      • Configuration Reference
  • User Guide
    • Topics
      • 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
    • Schemas
    • Connectors
      • Sources
      • Sinks
      • Secret Providers
    • Monitoring & Alerting
      • Infrastructure Health
      • Alerting
        • Alert Reference
      • Integrations
      • Consumer Groups
    • Self Service & Governance
      • Data policies
      • Audits
      • Kafka ACLs
      • Kafka Quotas
    • Lenses SQL
      • SQL Studio
        • Concepts
        • Best practices
        • Creating & deleting Kafka topics
        • Filtering
        • Limit & Sampling
        • Joins
        • Inserting & deleting data
        • Aggregations
        • Metadata fields
        • Views & synonyms
        • Arrays
        • Managing queries
      • SQL Processors
        • Concepts
        • Projections
        • Joins
        • Lateral Joins
        • Aggregations
        • Time & Windows
        • Storage format
        • Nullibility
        • Settings
      • 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
    • Topology
      • Registering via SDK
      • Registring via REST
    • License
    • CLI
      • Data
        • Datasets
        • Data Policies
        • Elasticsearch
        • Kafka topics
        • Querying data
      • Admin
        • Alerts
        • Alert Channels
        • Audit Channels
        • Connections
        • Groups
        • Schemas
        • Service Accounts
        • License
        • Users
      • Applications
        • Kafka Connectors
        • SQL Processors
      • Manage Kafka
        • ACLs
        • Consumers
        • Quotas
      • Golang client
  • Resources
    • Support & Community
    • Tutorials
      • SQL Studio
        • Querying data
        • Accessing headers
        • Deleting data from compacted topics
        • Working with JSON
      • 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
    • Downloads
    • API Reference
      • Authentication API
      • Lenses API Spec
      • Websocket Spec
      • Provisioning API Spec
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

Was this helpful?

Export as PDF
  1. Resources
  2. Tutorials
  3. SQL Studio

Accessing headers

This page describes a tutorial for access headers via SQL Studio.

Since version 0.11, Apache Kafka supports message headers. Headers are a typical concept in messaging systems like JMS and transport systems like TCP or HTTP.

They can be used for routing, filtering, and annotation. The header can contain pairs of key=value, where the key is always a string(text), and the value is an array of bytes.

Given that the actual value is an array of bytes, the developer who produces the messages knows whether this array of bytes represents a string, an int, a long, or a double. Lenses can visualize and use the record headers via SQL queries.

By default, Lenses fetches the headers of messages and displays them on the UI.

To view the value of a specific header you can run:

SELECT HEADERASSTRING("User") as user
FROM trips
LIMIT 100
PreviousQuerying dataNextDeleting data from compacted topics

Last updated 9 months ago

Was this helpful?