There is a nearly-as-simple solution involving lambda (which would not require running a kafka cluster) but meh.