KSQL Demo

The following demo example, creates a stream and topics, performs a non-persistent query, and a persistent query.

Setup

The following instructions sets up your environment for querying.

Create a default stream using /sample-stream:

maprcli stream create -path /sample-stream 
	-produceperm p -consumeperm p -topicperm p

Run the following script to generate some test data that is written to a HPE Ezmeral Data Fabric Event Store topic:
```
./bin/ksql-datagen quickstart=pageviews format=delimited 
	topic=/sample-stream:pageviews maxInterval=10000
```

Run KSQL CLI and create a KSQL table:

> ./bin/ksql
ksql> CREATE TABLE pageviews_original_table 
	(viewtime bigint, userid varchar, pageid varchar) 
	WITH (kafka_topic='/sample-stream:pageviews', value_format='DELIMITED', key='viewtime');

Run the following to list your KSQL tables:
```
ksql> SHOW TABLES;
```

Run a Non-persistent Query

For a NON-persistent query, run:

ksql> SELECT * FROM pageviews_original_table;

Run a Persistent Query

For a persistent query, do the following:

Create the topic, /sample-stream:input-topic:

maprcli stream topic create -path /sample-stream -topic input-topic

Create a KSQL input stream:

ksql> CREATE STREAM stream1 (message varchar) WITH 
	(kafka_topic='/sample-stream:input-topic' , value_format='DELIMITED');

Create persistent query with filtering:

ksql> CREATE STREAM stream2 
	WITH (kafka_topic='/sample-stream:output-topic' , value_format='DELIMITED') 
	AS SELECT * FROM stream1 WHERE LEN(message) > 2;

List your queries:
```
ksql> SHOW QUERIES;
```

Run the provided sample code for the console producer:

/opt/mapr/kafka/kafka-<version>/bin/kafka-console-producer.sh 
	--broker-list fake.server.id:9092 --topic /sample-stream:input-topic

Run the provided sample code for the console consumer:

/opt/mapr/kafka/kafka-<version>/bin/kafka-console-consumer.sh 
	--bootstrap-server fake.server.id:9092 
	--topic /sample-stream:output-topic

Produce some data:
```
>Hi
>Hello
>No
>Yes
```
Get the next results:
```
Hello 
Yes
```

Auxiliary Scripts Location

The sample code for kafka-console-producer.sh and kafka-console-consumer.sh is packaged with MapR Kafka. Once MapR Kafka is installed, you can find them at:

/opt/mapr/kafka/kafka-<version>/bin/