org.apache.beam.sdk.io.kafka

Interface KafkaPublishTimestampFunction<T>

All Superinterfaces:

java.io.Serializable

public interface KafkaPublishTimestampFunction<T>
extends java.io.Serializable

An interface for providing custom timestamp for elements written to Kafka.

Method Summary

Modifier and Type	Method and Description
Instant	getTimestamp(T element, Instant elementTimestamp) Returns timestamp for element being published to Kafka.
static <T> KafkaPublishTimestampFunction<T>	withElementTimestamp() Returns KafkaPublishTimestampFunction returns element timestamp from ProcessContext.

Method Detail

getTimestamp

Instant getTimestamp(T element,
                     Instant elementTimestamp)

Returns timestamp for element being published to Kafka. See @ProducerRecord.

Parameters:

element - The element being published.

elementTimestamp - Timestamp of the element from the context (i.e. @DoFn.ProcessContext#timestamp()

withElementTimestamp

static <T> KafkaPublishTimestampFunction<T> withElementTimestamp()

Returns KafkaPublishTimestampFunction returns element timestamp from ProcessContext.