modify examples for the new producer/consumer api
Add EventConsumer API