converted the toplogy to read events from Kafka