org.apache.beam.sdk.io.kafka

Class KafkaReadSchemaTransformConfiguration.Builder

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformConfiguration.Builder

Enclosing class:

KafkaReadSchemaTransformConfiguration

public abstract static class KafkaReadSchemaTransformConfiguration.Builder
extends java.lang.Object

Builder for the KafkaReadSchemaTransformConfiguration.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract KafkaReadSchemaTransformConfiguration	build() Builds a KafkaReadSchemaTransformConfiguration instance.
abstract KafkaReadSchemaTransformConfiguration.Builder	setAutoOffsetResetConfig(java.lang.String startOffset)
abstract KafkaReadSchemaTransformConfiguration.Builder	setBootstrapServers(java.lang.String value) Sets the bootstrap servers for the Kafka consumer.
abstract KafkaReadSchemaTransformConfiguration.Builder	setConfluentSchemaRegistrySubject(java.lang.String subject)
abstract KafkaReadSchemaTransformConfiguration.Builder	setConfluentSchemaRegistryUrl(java.lang.String schemaRegistry)
abstract KafkaReadSchemaTransformConfiguration.Builder	setConsumerConfigUpdates(java.util.Map<java.lang.String,java.lang.String> consumerConfigUpdates)
abstract KafkaReadSchemaTransformConfiguration.Builder	setErrorHandling(ErrorHandling errorHandling)
abstract KafkaReadSchemaTransformConfiguration.Builder	setFileDescriptorPath(java.lang.String fileDescriptorPath)
abstract KafkaReadSchemaTransformConfiguration.Builder	setFormat(java.lang.String format)
abstract KafkaReadSchemaTransformConfiguration.Builder	setMaxReadTimeSeconds(java.lang.Integer maxReadTimeSeconds)
abstract KafkaReadSchemaTransformConfiguration.Builder	setMessageName(java.lang.String messageName)
abstract KafkaReadSchemaTransformConfiguration.Builder	setSchema(java.lang.String schema)
abstract KafkaReadSchemaTransformConfiguration.Builder	setTopic(java.lang.String value) Sets the topic from which to read.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setBootstrapServers

public abstract KafkaReadSchemaTransformConfiguration.Builder setBootstrapServers(java.lang.String value)

Sets the bootstrap servers for the Kafka consumer.

setConfluentSchemaRegistryUrl

public abstract KafkaReadSchemaTransformConfiguration.Builder setConfluentSchemaRegistryUrl(java.lang.String schemaRegistry)

setConfluentSchemaRegistrySubject

public abstract KafkaReadSchemaTransformConfiguration.Builder setConfluentSchemaRegistrySubject(java.lang.String subject)

setSchema

public abstract KafkaReadSchemaTransformConfiguration.Builder setSchema(java.lang.String schema)

setFileDescriptorPath

public abstract KafkaReadSchemaTransformConfiguration.Builder setFileDescriptorPath(java.lang.String fileDescriptorPath)

setMessageName

public abstract KafkaReadSchemaTransformConfiguration.Builder setMessageName(java.lang.String messageName)

setFormat

public abstract KafkaReadSchemaTransformConfiguration.Builder setFormat(java.lang.String format)

setAutoOffsetResetConfig

public abstract KafkaReadSchemaTransformConfiguration.Builder setAutoOffsetResetConfig(java.lang.String startOffset)

setConsumerConfigUpdates

public abstract KafkaReadSchemaTransformConfiguration.Builder setConsumerConfigUpdates(java.util.Map<java.lang.String,java.lang.String> consumerConfigUpdates)

setTopic

public abstract KafkaReadSchemaTransformConfiguration.Builder setTopic(java.lang.String value)

Sets the topic from which to read.

setMaxReadTimeSeconds

public abstract KafkaReadSchemaTransformConfiguration.Builder setMaxReadTimeSeconds(java.lang.Integer maxReadTimeSeconds)

setErrorHandling

public abstract KafkaReadSchemaTransformConfiguration.Builder setErrorHandling(ErrorHandling errorHandling)

build

public abstract KafkaReadSchemaTransformConfiguration build()

Builds a KafkaReadSchemaTransformConfiguration instance.