Function producer

pub async fn producer(broker_addr: &str, datadir: String)

Create a kafka producer for the topics and data in datadir.