Replaces direct use of aiokafka with osm_common message bus in agent and