Create New Stream

Map a technical topic or table to a stream definition.

Stream Context

Select the source/sink connection.

Connection

Display Name

Streams map physical data sources (Topics, Queues, Tables) to ControlStream's internal logic.

KAFKA Configuration

Define technical details for the selected connection.

create

Type

Topic Name

Technical Name is the source of truth.

Correlation Strategy

Required

Location

Key Name

Kafka Options

Consumer Group (optional)

Correlation Header (optional)

Payload Decoding

Configure schema source and format hint for decoding payloads.

optional

Schema Source

Format Hint

Definition Preview

{
  "name": "",
  "type": "KAFKA",
  "connectionId": "",
  "technicalName": "",
  "correlationKeyType": "HEADER",
  "correlationKeyName": "trace-id",
  "vendorConfig": {
    "vendor": "KAFKA"
  },
  "decoding": {
    "schemaSource": "NONE",
    "formatHint": "AUTO"
  }
}