Striim 3.9.7 documentation

For an overview of this feature, see Introducing Kafka streams.

Reading from a Kafka stream can be useful for development tasks such as doing A/B comparisons of variations on a TQL application. If you modified Samples.PosApp.tql to persist PosDataStream to Kafka, the following source would read the persisted data from Kafka.

CREATE SOURCE AccessLogSource USING KafkaReader VERSION 0.11.0(
  brokerAddress:'localhost:9998',
  Topic:'Samples_PosDataStream',
  PartitionIDList:'0',
  startOffset:0
)
PARSE USING StriimParser ()
OUTPUT TO KafkaDSVStream;