Sample siddhi application to read from a Kafka topic and publish through a WebSocket server

KafkaToWebSocket.siddhi

@App:name("KafkaToWebSocket")

@App:description('Consume events from a Kafka Topic and log the messages on the console.')

@source(type='kafka',
        topic.list='productions',
        threading.option='single.thread',
        group.id="group1",
        bootstrap.servers='localhost:9092',
        @map(type='json'))
define stream SweetProductionStream (name string, amount double);

@sink(type='websocket-server', host='localhost', port='8025', 
@map(type='json'))
define stream LowProductionAlertStream (name string, amount double);

@sink(type='log')
define stream OutputStream (name string, amount double);

from SweetProductionStream
select str:upper(name) as name, amount
insert into OutputStream;

from SweetProductionStream[amount < 500]
select str:upper(name) as name, amount
insert into LowProductionAlertStream;