Timeplus

This page describes how to integrate WarpStream with Timeplus, to perform SQL commands on a data stream to perform queries, transformations and ETL.

A video walkthrough can be found below:

Timeplus is a streaming-first data analytics platform based on the open-source project Proton that integrates with WarpStream to ingest data from your WarpStream topics. For more information on configuring Timeplus to consume data from WarpStream, please review the Timeplus Proton integration documentation.

You can connect Proton with a local deployment of WarpStream or WarpStream Serverless Cloud.

Example:

CREATE EXTERNAL STREAM ext_stream(raw string)
SETTINGS type='kafka',
         brokers='serverless.warpstream.com:9092',
         topic='topic',
         security_protocol='SASL_SSL',
         sasl_mechanism='PLAIN',
         username='..',
         password='..'

sasl_mechanism can be either PLAIN or SCRAM-SHA-512, but cannot be SCRAM-SHA-256.