[SO] Code improvement in bpmn-infra supporting kafka change