modify example to use Kafka as the messaging system.