That should be already possible, using an [broker input](https://docs.redpanda.com/redpanda-connect/components/inputs/broker/). But there is no automation yet.