Fixed and updated code examples from the book "Apache Kafka" - View it on GitHub