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

No match.