org.apache.beam.sdk.io.kafka

Class KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration

Enclosing class:

KafkaSchemaTransformReadConfiguration

@Experimental
 @DefaultSchema(value=AutoValueSchema.class)
public abstract static class KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration
extends java.lang.Object

A configuration for a TopicPartition.

Internal only: This class is actively being worked on, and it will likely change. We provide no backwards compatibility guarantees, and it should not be implemented outside the Beam repository.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder Builder for the KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.

Constructor Summary

Constructors

Constructor and Description
TopicPartitionConfiguration()

Method Summary

Modifier and Type	Method and Description
static KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder	builder() Instantiates a KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder instance.
abstract java.lang.Integer	getPartition() The number of the topic partition.
abstract java.lang.String	getTopic() The name of the topic defining the partition.

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicPartitionConfiguration

public TopicPartitionConfiguration()

Method Detail

builder

public static KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder builder()

Instantiates a KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder instance.

getTopic

public abstract java.lang.String getTopic()

The name of the topic defining the partition.

getPartition

public abstract java.lang.Integer getPartition()

The number of the topic partition.