Regarding the Drainer Plugin framework, it would be awesome to add LIftBridge.
LIftBridge is like Kafka but is 100% golang, with a GRPC API, and so easy to use.
https://liftbridge.io/
API: https://github.com/liftbridge-io/liftbridge-api/blob/master/api.proto