public class HeaderUtils extends Object
Modifier and Type | Field and Description |
---|---|
protected String |
artifactIdHeaderName |
static String |
DEFAULT_HEADER_KEY_ARTIFACT_ID |
static String |
DEFAULT_HEADER_KEY_GLOBAL_ID |
static String |
DEFAULT_HEADER_KEY_VERSION |
static String |
DEFAULT_HEADER_VALUE_ARTIFACT_ID |
static String |
DEFAULT_HEADER_VALUE_GLOBAL_ID |
static String |
DEFAULT_HEADER_VALUE_VERSION |
protected String |
encodingName |
protected String |
globalIdHeaderName |
static String |
HEADER_KEY_ARTIFACT_ID_OVERRIDE_NAME |
static String |
HEADER_KEY_ENCODING |
static String |
HEADER_KEY_GLOBAL_ID_OVERRIDE_NAME |
static String |
HEADER_KEY_VERSION_OVERRIDE_NAME |
static String |
HEADER_VALUE_ARTIFACT_ID_OVERRIDE_NAME |
static String |
HEADER_VALUE_ENCODING |
static String |
HEADER_VALUE_GLOBAL_ID_OVERRIDE_NAME |
static String |
HEADER_VALUE_VERSION_OVERRIDE_NAME |
protected String |
versionHeaderName |
Constructor and Description |
---|
HeaderUtils(Map<String,Object> configs,
boolean isKey) |
Modifier and Type | Method and Description |
---|---|
void |
addEncodingHeader(org.apache.kafka.common.header.Headers headers,
AvroEncoding encoding) |
void |
addSchemaHeaders(org.apache.kafka.common.header.Headers headers,
String artifactId,
long globalId)
Adds appropriate information to the Headers so that the deserializer can function properly.
|
static org.apache.kafka.common.header.Headers |
createHeaders()
Create an empty set of Kafka headers.
|
static org.apache.kafka.common.header.Headers |
createHeaders(Map<String,String> mapObj)
Create Kafka headers from a map of String keys and String values.
|
String |
getArtifactId(org.apache.kafka.common.header.Headers headers) |
AvroEncoding |
getEncoding(org.apache.kafka.common.header.Headers headers) |
Long |
getGlobalId(org.apache.kafka.common.header.Headers headers) |
Integer |
getVersion(org.apache.kafka.common.header.Headers headers) |
public static final String DEFAULT_HEADER_KEY_ARTIFACT_ID
public static final String DEFAULT_HEADER_VALUE_ARTIFACT_ID
public static final String DEFAULT_HEADER_KEY_VERSION
public static final String DEFAULT_HEADER_VALUE_VERSION
public static final String DEFAULT_HEADER_KEY_GLOBAL_ID
public static final String DEFAULT_HEADER_VALUE_GLOBAL_ID
public static final String HEADER_KEY_ENCODING
public static final String HEADER_VALUE_ENCODING
public static final String HEADER_KEY_ARTIFACT_ID_OVERRIDE_NAME
public static final String HEADER_VALUE_ARTIFACT_ID_OVERRIDE_NAME
public static final String HEADER_KEY_VERSION_OVERRIDE_NAME
public static final String HEADER_VALUE_VERSION_OVERRIDE_NAME
public static final String HEADER_KEY_GLOBAL_ID_OVERRIDE_NAME
public static final String HEADER_VALUE_GLOBAL_ID_OVERRIDE_NAME
protected String globalIdHeaderName
protected String artifactIdHeaderName
protected String versionHeaderName
protected String encodingName
public void addSchemaHeaders(org.apache.kafka.common.header.Headers headers, String artifactId, long globalId)
headers
- msg headersartifactId
- artifact idglobalId
- global idpublic void addEncodingHeader(org.apache.kafka.common.header.Headers headers, AvroEncoding encoding)
public AvroEncoding getEncoding(org.apache.kafka.common.header.Headers headers)
public String getArtifactId(org.apache.kafka.common.header.Headers headers)
public Integer getVersion(org.apache.kafka.common.header.Headers headers)
public Long getGlobalId(org.apache.kafka.common.header.Headers headers)
public static org.apache.kafka.common.header.Headers createHeaders()
Copyright © 2020 Red Hat. All rights reserved.