public abstract class AbstractKafkaHeaderMapper extends java.lang.Object implements KafkaHeaderMapper
| Modifier and Type | Class and Description |
|---|---|
protected static class |
AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher
A pattern-based header matcher that matches if the specified
header matches the specified simple pattern.
|
| Modifier and Type | Field and Description |
|---|---|
protected org.apache.commons.logging.Log |
logger |
protected java.util.List<AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher> |
matchers |
| Constructor and Description |
|---|
AbstractKafkaHeaderMapper(java.lang.String... patterns) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
matches(java.lang.String header) |
protected boolean |
matches(java.lang.String header,
java.lang.Object value) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitfromHeaders, toHeadersprotected final org.apache.commons.logging.Log logger
protected final java.util.List<AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher> matchers