run
bin/kafka-manager -Dconfig.file=/path/to/conf/application.conf
https://docs.confluent.io/current/installation/docker/docs/quickstart.html
https://docs.confluent.io/current/installation/installing_cp/index.html
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"
offset
SET 'auto.offset.reset' = 'earliest';