fixing the kafka transport