Before implementing return Kafka messages from the connectors to the engine, we need to simplify the current code in the eventing-integrations project. That code (or a variation of it) will be reused in all connectors.