Turn into lib

Turn into a library, so we can save the roundtrip to kafka