Package org.springframework.kafka.streams

Class HeaderEnricherProcessor<K,V>

java.lang.Object

org.apache.kafka.streams.processor.api.ContextualProcessor<K,V,K,V>

org.springframework.kafka.streams.HeaderEnricherProcessor<K,V>

Type Parameters:

K - the input key type.

V - the input value type.

All Implemented Interfaces:

org.apache.kafka.streams.processor.api.Processor<K,V,K,V>

public class HeaderEnricherProcessor<K,V>
extends org.apache.kafka.streams.processor.api.ContextualProcessor<K,V,K,V>

Manipulate the headers.

Since:

3.0

Author:

Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	HeaderEnricherProcessor.Container<K,V>	Container object for SpEL evaluation.

Constructor Summary

Constructors

Constructor	Description
HeaderEnricherProcessor(Map<String,Expression> headerExpressions)	Construct an instance with the provided header expressions.

Method Summary

Modifier and Type	Method	Description
void	close()
void	process(org.apache.kafka.streams.processor.api.Record<K,V> record)

Methods inherited from class org.apache.kafka.streams.processor.api.ContextualProcessor

context, init

Methods inherited from class java.lang.Object

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

Constructor Details

HeaderEnricherProcessor

public HeaderEnricherProcessor(Map<String,Expression> headerExpressions)

Construct an instance with the provided header expressions.

Parameters:

headerExpressions - the header expressions; name:expression.

Method Details

process

public void process(org.apache.kafka.streams.processor.api.Record<K,V> record)

close

public void close()