applying local logging changes to kafka fork