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

Interface TimestampSource

All Known Implementing Classes:

TimestampSource.EventTimestampSource, TimestampSource.WallclockTimestampSource

public interface TimestampSource

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	TimestampSource.EventTimestampSource
static enum	TimestampSource.Type
static final class	TimestampSource.WallclockTimestampSource

Method Summary

Modifier and Type	Method	Description
static TimestampSource	of(TimestampSource.Type extractorType)
static TimestampSource	of(ZoneId zoneId, TimestampSource.Type extractorType)
ZonedDateTime	time(org.apache.kafka.connect.sink.SinkRecord record)
TimestampSource.Type	type()

Method Details

time

ZonedDateTime time(org.apache.kafka.connect.sink.SinkRecord record)

of

static TimestampSource of(TimestampSource.Type extractorType)

of

static TimestampSource of(ZoneId zoneId,
 TimestampSource.Type extractorType)

type

TimestampSource.Type type()