Add integration tests

[Dotunj]

My idea for integration testing is to spin up the actual message brokers (Kafka, RabbitMQ) or use an emulator (SQS, Google Pub/Sub) and verify we can publish to them without any errors.

How can we assert these messages were delivered?