Kafka KSQL examples

monitoring:

• https://github.com/framiere/monitoring-demo
• https://github.com/yahoo/kafka-manager

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