Streambased Documentation
  • Home
  • Overview
    • Key Concepts
  • Streambased Cloud
    • Streambased Cloud UI
      • Create your first Streambased cluster
      • Create your first Streambased API Key
      • Running your first A.S.K Query
      • Exploring your data using S.S.K
    • Iceberg Service for Kafka - I.S.K.
      • Overview
      • Architecture
      • Usage
      • Quick Start
    • Analytics Service for Kafka - A.S.K.
      • Overview
      • Architecture
      • Connecting to Streambased A.S.K.
        • Connect Superset to Streambased A.S.K.
        • Connect Jupyter to Streambased A.S.K.
        • Connect a JDBC Client to Streambased A.S.K.
        • Connect an ODBC client to Streambased A.S.K.
        • Connect a Python Application (SQL Alchemy) to Streambased A.S.K.
    • Storage Service for Kafka - S.S.K.
      • Overview
      • Connecting to Streambased S.S.K.
        • Connecting a S3 compatible client to Streambased S.S.K.
        • Connect a S3manager to Streambased S.S.K.
  • Streambased Platform
    • Overview
    • Requirements
    • Step by Step Installation
    • Configuration
      • Dynamic Configuration
    • Connecting Analytical Applications to Streambased
      • Connect Superset to Streambased
      • Connect Jupyter to Streambased
      • Connect a JDBC Client to Streambased
      • Connect an ODBC client to Streambased
      • Connect a Python Application (SQL Alchemy) to Streambased
Powered by GitBook
On this page
  1. Streambased Platform
  2. Configuration

Dynamic Configuration

PreviousConfigurationNextConnecting Analytical Applications to Streambased

Last updated 7 days ago

Many of the Streambased configuration properties related to indexing and Kafka sources can also be configured using specialist SQL at runtime.

The following configuration objects can be modified:

  • Sources

  • Extractors

  • Transformers

  • Aggregators

Listing configuration objects

Configurations can be listed via the following syntax:

SHOW STREAMBASED [SOURCE/EXTRACTOR/TRANSFORMER/AGGREGATOR]

Adding/Modifying a new configuration object

Configurations can be added or updated via the following syntax:

[CREATE/UPDATE] STREAMBASED [SOURCE/EXTRACTOR/TRANSFORMER/AGGREGATOR] [config object name] WITH [json payload]

Where config object name is the name of the Source/Extractor/Transformer/Aggregator you are working with and json payload contains un-prefixed versions of the properties described . e.g.:

{
  "source" : "someKafka",
  "topic" : "someTopic",
  "class" : "com.example.someExtractor"
}

Deleting a configuration object

Configurations can be deleted via the following syntax:

DROP STREAMBASED [SOURCE/EXTRACTOR/TRANSFORMER/AGGREGATOR] [config object name]

Where config object name is the name of the Source/Extractor/Transformer/Aggregator you are working with.

here