Reading a Kafka stream with KafkaReader
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;
For more information, see Kafka Reader.