$ 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