Inital code for kafka transport example