/ksql-examples

data generator for exploring kafka's topics contents with kstreams and ktables

Primary LanguageScala

Kafka KSQL examples

monitoring:

kafka manager

configure and deploy

run

  bin/kafka-manager -Dconfig.file=/path/to/conf/application.conf

install

from docker

https://docs.confluent.io/current/installation/docker/docs/quickstart.html

from confluent applications

https://docs.confluent.io/current/installation/installing_cp/index.html

CLI

run confluent platform

  bin/confluent start

list topic

  bin/kafka-topics --list --zookeeper localhost:2181

producer

  bin/kafka-console-producer --broker-list "localhost:9092" --topic "ksqlexamples.show-opinions"  

KSQL

offset

  SET 'auto.offset.reset' = 'earliest';

k-streams

k-table