package core.framework.internal.kafka;

/**
 * @author neo
 */
public final class MessageHeaders {
    public static final String HEADER_CORRELATION_ID = "correlationId";
    public static final String HEADER_TRACE = "trace";
    public static final String HEADER_CLIENT = "client";
    public static final String HEADER_REF_ID = "refId";
}
