Kafka example
Fixes #1028
25 files changed