Add event generation code to kafka channel code.