org.springframework.cloud.stream.binder.kafka

Class BinderHeaderMapper

java.lang.Object

org.springframework.kafka.support.AbstractKafkaHeaderMapper

org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper

All Implemented Interfaces:

org.springframework.kafka.support.KafkaHeaderMapper

Deprecated.

@Deprecated
public class BinderHeaderMapper
extends org.springframework.kafka.support.AbstractKafkaHeaderMapper

Default header mapper for Apache Kafka. Most headers in KafkaHeaders are not mapped on outbound messages. The exceptions are correlation and reply headers for request/reply messaging. Header types are added to a special header JSON_TYPES.

Since:

2.0.2

Author:

Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BinderHeaderMapper.NonTrustedHeaderType Deprecated. Represents a header that could not be decoded due to an untrusted type.

Nested classes/interfaces inherited from class org.springframework.kafka.support.AbstractKafkaHeaderMapper

org.springframework.kafka.support.AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher

Field Summary

Fields

Modifier and Type	Field and Description
static String	JSON_TYPES Deprecated. Header name for java types of other headers.

Fields inherited from class org.springframework.kafka.support.AbstractKafkaHeaderMapper

logger, matchers

Constructor Summary

Constructors

Constructor and Description
BinderHeaderMapper() Deprecated. Construct an instance with the default object mapper and default header patterns for outbound headers; all inbound headers are mapped.
BinderHeaderMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper) Deprecated. Construct an instance with the provided object mapper and default header patterns for outbound headers; all inbound headers are mapped.
BinderHeaderMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper, String... patterns) Deprecated. Construct an instance with the provided object mapper and the provided header patterns for outbound headers; all inbound headers are mapped.
BinderHeaderMapper(String... patterns) Deprecated. Construct an instance with a default object mapper and the provided header patterns for outbound headers; all inbound headers are mapped.

Method Summary

Modifier and Type	Method and Description
void	addToStringClasses(String... classNames) Deprecated. Add class names that the outbound mapper should perform toString() operations on before mapping.
void	addTrustedPackages(String... trustedPackages) Deprecated. Add packages to the trusted packages list (default java.util, java.lang) used when constructing objects from JSON.
void	fromHeaders(org.springframework.messaging.MessageHeaders headers, org.apache.kafka.common.header.Headers target) Deprecated.
protected com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper() Deprecated. Return the object mapper.
protected Set<String>	getToStringClasses() Deprecated. Provide direct access to the toString() classes by subclasses.
protected Set<String>	getTrustedPackages() Deprecated. Provide direct access to the trusted packages set for subclasses.
void	toHeaders(org.apache.kafka.common.header.Headers source, Map<String,Object> headers) Deprecated.
protected boolean	trusted(String requestedType) Deprecated.

Methods inherited from class org.springframework.kafka.support.AbstractKafkaHeaderMapper

matches, matches

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

JSON_TYPES

public static final String JSON_TYPES

Deprecated.

Header name for java types of other headers.

See Also:

Constant Field Values

Constructor Detail

BinderHeaderMapper

public BinderHeaderMapper()

Deprecated.

Construct an instance with the default object mapper and default header patterns for outbound headers; all inbound headers are mapped. The default pattern list is "!id", "!timestamp" and "*". In addition, most of the headers in KafkaHeaders are never mapped as headers since they represent data in consumer/producer records.

See Also:

BinderHeaderMapper(ObjectMapper)

BinderHeaderMapper

public BinderHeaderMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Deprecated.

Construct an instance with the provided object mapper and default header patterns for outbound headers; all inbound headers are mapped. The patterns are applied in order, stopping on the first match (positive or negative). Patterns are negated by preceding them with "!". The default pattern list is "!id", "!timestamp" and "*". In addition, most of the headers in KafkaHeaders are never mapped as headers since they represent data in consumer/producer records.

Parameters:

objectMapper - the object mapper.

See Also:

PatternMatchUtils.simpleMatch(String, String)

BinderHeaderMapper

public BinderHeaderMapper(String... patterns)

Deprecated.

Construct an instance with a default object mapper and the provided header patterns for outbound headers; all inbound headers are mapped. The patterns are applied in order, stopping on the first match (positive or negative). Patterns are negated by preceding them with "!". The patterns will replace the default patterns; you generally should not map the "id" and "timestamp" headers. Note: most of the headers in KafkaHeaders are ever mapped as headers since they represent data in consumer/producer records.

Parameters:

patterns - the patterns.

See Also:

PatternMatchUtils.simpleMatch(String, String)

BinderHeaderMapper

public BinderHeaderMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                          String... patterns)

Deprecated.

Construct an instance with the provided object mapper and the provided header patterns for outbound headers; all inbound headers are mapped. The patterns are applied in order, stopping on the first match (positive or negative). Patterns are negated by preceding them with "!". The patterns will replace the default patterns; you generally should not map the "id" and "timestamp" headers. Note: most of the headers in KafkaHeaders are never mapped as headers since they represent data in consumer/producer records.

Parameters:

objectMapper - the object mapper.

patterns - the patterns.

See Also:

PatternMatchUtils.simpleMatch(String, String)

Method Detail

getObjectMapper

protected com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()

Deprecated.

Return the object mapper.

Returns:

the mapper.

getTrustedPackages

protected Set<String> getTrustedPackages()

Deprecated.

Provide direct access to the trusted packages set for subclasses.

Returns:

the trusted packages.

Since:

2.2

getToStringClasses

protected Set<String> getToStringClasses()

Deprecated.

Provide direct access to the toString() classes by subclasses.

Returns:

the toString() classes.

Since:

2.2

addTrustedPackages

public void addTrustedPackages(String... trustedPackages)

Deprecated.

Add packages to the trusted packages list (default java.util, java.lang) used when constructing objects from JSON. If any of the supplied packages is "*", all packages are trusted. If a class for a non-trusted package is encountered, the header is returned to the application with value of type BinderHeaderMapper.NonTrustedHeaderType.

Parameters:

trustedPackages - the packages to trust.

addToStringClasses

public void addToStringClasses(String... classNames)

Deprecated.

Add class names that the outbound mapper should perform toString() operations on before mapping.

Parameters:

classNames - the class names.

Since:

2.2

fromHeaders

public void fromHeaders(org.springframework.messaging.MessageHeaders headers,
                        org.apache.kafka.common.header.Headers target)

Deprecated.

toHeaders

public void toHeaders(org.apache.kafka.common.header.Headers source,
                      Map<String,Object> headers)

Deprecated.

trusted

protected boolean trusted(String requestedType)

Deprecated.