in src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/AsyncDataLoadKafkaListener.java [224:237]
private RequestContext buildRequestContext(MessageHeaders headers) {
RequestContext context = new RequestContext();
context.setApplication(getFromHeaders(headers, X_SOURCE_APPLICATION));
context.setSystem(getFromHeaders(headers, X_SOURCE_SYSTEM));
context.setBusinessProcess(getFromHeaders(headers, X_SOURCE_BUSINESS_PROCESS));
context.setBusinessProcessInstanceId(
getFromHeaders(headers, X_SOURCE_BUSINESS_PROCESS_INSTANCE_ID));
context.setBusinessActivity(getFromHeaders(headers, X_SOURCE_BUSINESS_ACTIVITY));
context.setBusinessActivityInstanceId(
getFromHeaders(headers, X_SOURCE_BUSINESS_ACTIVITY_INSTANCE_ID));
context.setBusinessProcessDefinitionId(
getFromHeaders(headers, X_SOURCE_BUSINESS_PROCESS_DEFINITION_ID));
return context;
}