Class HeaderEnricher<K,V>

java.lang.Object
org.springframework.kafka.streams.HeaderEnricher<K,V>
Type Parameters:
K - the key type.
V - the value type.
All Implemented Interfaces:
org.apache.kafka.streams.kstream.Transformer<K,V,org.apache.kafka.streams.KeyValue<K,V>>

@Deprecated public class HeaderEnricher<K,V> extends Object implements org.apache.kafka.streams.kstream.Transformer<K,V,org.apache.kafka.streams.KeyValue<K,V>>
Deprecated.
Manipulate the headers.
Since:
2.3
Author:
Gary Russell
  • Constructor Details

  • Method Details

    • init

      public void init(org.apache.kafka.streams.processor.ProcessorContext context)
      Deprecated.
      Specified by:
      init in interface org.apache.kafka.streams.kstream.Transformer<K,V,org.apache.kafka.streams.KeyValue<K,V>>
    • transform

      public org.apache.kafka.streams.KeyValue<K,V> transform(K key, V value)
      Deprecated.
      Specified by:
      transform in interface org.apache.kafka.streams.kstream.Transformer<K,V,org.apache.kafka.streams.KeyValue<K,V>>
    • close

      public void close()
      Deprecated.
      Specified by:
      close in interface org.apache.kafka.streams.kstream.Transformer<K,V,org.apache.kafka.streams.KeyValue<K,V>>