APM Queue Producing and Consuming library that abstracts the details of producing and consuming records to and from Kafka / GCP PubSubLite.