Pasted

k8-kafka-console-consumer --topic raw_pageviews | grep '^{' | pv -l -i10 -r > /dev/null
++ k8-get-pod-name kafka
+ pod=kafka-0
+ exec kubectl exec -ti kafka-0 -c kafka -- /kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic raw_pageviews
[13,6 /s]