marsattacks20

This also works. std::unique_ptr bin_os = avro::memoryOutputStream(); avroencoder->init(*bin_os.get()); . . . std::vector out; std::shared_ptr v = avro::snapshot(*bin_os.get()); out.insert(out.end(), v->begin(), v->end()); kafkabuilder.payload(out); kafkaproducer.produce(kafkabuilder);