Dynamic Configuration

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 here. 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.