Untitled

<!DOCTYPE html>
<meta charset="utf-8"/>
<title>Kafka WebSocket Test</title>

<script language="javascript" type="text/javascript">

    var topics = 'wstest';
    var uri = 'ws://localhost:7080/v1/topics/' + topics;

    var ws = new WebSocket(uri);

    ws.onopen = function(ev) {
        console.log('open', ev);
    }

    ws.onclose = function(ev) {
        console.log('close', ev);
    }

    ws.onmessage = function(ev) {
        console.log('message', ev);
    }

    ws.onerror = function(ev) {
        console.log('error', ev);
    }

    setInterval(function() {
        var message = {
            topic : 'wstest',
            message : 'some message ' + new Date()
        }
        ws.send(JSON.stringify(message));
    }, 1000)

</script>