Kafka sample code