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 and Description
Header	apply(Header header) Transform the given Header and return the updated Header.

Method Detail

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