Pipe Code Sample
Provides sample code for a Pipe example.
The following is a Pipe code sample that moves an inputTopic to an outputTopic:
ksql> CREATE STREAM stream3 (message varchar) WITH (kafka_topic='/sample-stream:inputTopic', value_format='DELIMITED');
ksql> CREATE STREAM stream4 WITH (kafka_topic='/sample-stream:streams-pipe-output1', value_format='DELIMITED') AS SELECT * FROM stream3;