org.apache.beam.sdk.io.kafka

Class KafkaSourceDescriptor

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaSourceDescriptor

All Implemented Interfaces:

java.io.Serializable

@DefaultSchema(value=AutoValueSchema.class)
public abstract class KafkaSourceDescriptor
extends java.lang.Object
implements java.io.Serializable

Represents a Kafka source description.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaSourceDescriptor()

Method Summary

Modifier and Type	Method and Description
TopicPartition	getTopicPartition()
static KafkaSourceDescriptor	of(TopicPartition topicPartition, @Nullable java.lang.Long startReadOffset, @Nullable Instant startReadTime, @Nullable java.lang.Long stopReadOffset, @Nullable Instant stopReadTime, @Nullable java.util.List<java.lang.String> bootstrapServers)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSourceDescriptor

public KafkaSourceDescriptor()

Method Detail

getTopicPartition

@SchemaIgnore
 @Deterministic
public TopicPartition getTopicPartition()

of

public static KafkaSourceDescriptor of(TopicPartition topicPartition,
                                       @Nullable java.lang.Long startReadOffset,
                                       @Nullable Instant startReadTime,
                                       @Nullable java.lang.Long stopReadOffset,
                                       @Nullable Instant stopReadTime,
                                       @Nullable java.util.List<java.lang.String> bootstrapServers)