[kafka] reference

$ kubectl port-forward kafka-0 -n kafka 9094

$ kafkacat -b localhost:9094 -L

$ kafkacat -P -b localhost:9094 -t topic1
$ kafkacat -C -b localhost:9094 -t topic1

$ kafkacat -C -b localhost:9094 -t topic1 \
 -f 'Key is %k, and message payload is: %s \n'

https://github.com/Yolean/kubernetes-kafka