Abstraction layer over Kafka / GCP PubSub Lite to produce and consume records - View it on GitHub