Send events with mqtt and read it from pulsar topic to validate - that all messages go through - cleanup resources - etc