This is a repo which contains an end to end sample for Kafka extension - View it on GitHub