Hi folks, I have been thinking about adding a gcp pubsub based sink to the mce ingestion route. I understand that this could potentially be a part of the contrib series of packages but the underlying goal here is to eliminate the dependency on Kafka and schema registry. Does contrib package make sense here? I can see a case for rfc as I could make a case for "pluggable message queue" or does that seem like an overkill. Thoughts?

This is amazing!! Feel free to do both at the same time. After thorough review (since it's a central part of the system) we can move it into the main repo!!

Yeah I think this would be quite useful for others as well. It’s really a matter of abstracting away the Kafka producer and Kafka consumers with one additional interface..