Package io.aiven.kafka.connect.common.config

Class StableTimeFormatter

java.lang.Object

io.aiven.kafka.connect.common.config.StableTimeFormatter

public class StableTimeFormatter
extends Object

Constructor Summary

Constructors

Constructor	Description
StableTimeFormatter(TimestampSource timestampSource)

Method Summary

Modifier and Type	Method	Description
Function<VariableTemplatePart.Parameter,String>	apply(org.apache.kafka.connect.sink.SinkRecord record)

Methods inherited from class java.lang.Object

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

Constructor Details

StableTimeFormatter

public StableTimeFormatter(TimestampSource timestampSource)

Method Details

apply

public Function<VariableTemplatePart.Parameter,String> apply(org.apache.kafka.connect.sink.SinkRecord record)