Package org.apache.kafka.connect.header

Interface Headers.HeaderTransform

Enclosing interface:
Headers
public static interface Headers.HeaderTransform
A function to transform the supplied Header. Implementations will likely need to use Header.with(Schema, Object) to create the new instance.

  • Method Summary

    Modifier and Type
    Method
    Description
    Header
    apply(Header header)
    Transform the given Header and return the updated Header.

  • Method Details

    • apply

      Header apply(Header header)
      Transform the given Header and return the updated Header.
      Parameters:
      header - the input header; never null
      Returns:
      the new header, or null if the supplied Header is to be removed