Package 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 Object

Builder for the KafkaReadSchemaTransformConfiguration.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract KafkaReadSchemaTransformConfiguration	build()	Builds a KafkaReadSchemaTransformConfiguration instance.
abstract KafkaReadSchemaTransformConfiguration.Builder	setAllowDuplicates(Boolean allowDuplicates)
abstract KafkaReadSchemaTransformConfiguration.Builder	setAutoOffsetResetConfig(String startOffset)
abstract KafkaReadSchemaTransformConfiguration.Builder	setBootstrapServers(String value)	Sets the bootstrap servers for the Kafka consumer.
abstract KafkaReadSchemaTransformConfiguration.Builder	setConfluentSchemaRegistrySubject(String subject)
abstract KafkaReadSchemaTransformConfiguration.Builder	setConfluentSchemaRegistryUrl(String schemaRegistry)
abstract KafkaReadSchemaTransformConfiguration.Builder	setConsumerConfigUpdates(Map<String,String> consumerConfigUpdates)
abstract KafkaReadSchemaTransformConfiguration.Builder	setErrorHandling(ErrorHandling errorHandling)
abstract KafkaReadSchemaTransformConfiguration.Builder	setFileDescriptorPath(String fileDescriptorPath)
abstract KafkaReadSchemaTransformConfiguration.Builder	setFormat(String format)
abstract KafkaReadSchemaTransformConfiguration.Builder	setMaxReadTimeSeconds(Integer maxReadTimeSeconds)
abstract KafkaReadSchemaTransformConfiguration.Builder	setMessageName(String messageName)
abstract KafkaReadSchemaTransformConfiguration.Builder	setOffsetDeduplication(Boolean offsetDeduplication)
abstract KafkaReadSchemaTransformConfiguration.Builder	setRedistributeByRecordKey(Boolean redistributeByRecordKey)
abstract KafkaReadSchemaTransformConfiguration.Builder	setRedistributed(Boolean redistribute)
abstract KafkaReadSchemaTransformConfiguration.Builder	setRedistributeNumKeys(Integer redistributeNumKeys)
abstract KafkaReadSchemaTransformConfiguration.Builder	setSchema(String schema)
abstract KafkaReadSchemaTransformConfiguration.Builder	setTopic(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 Details

Builder

public Builder()

Method Details

setBootstrapServers

public abstract KafkaReadSchemaTransformConfiguration.Builder setBootstrapServers(String value)

Sets the bootstrap servers for the Kafka consumer.

setConfluentSchemaRegistryUrl

public abstract KafkaReadSchemaTransformConfiguration.Builder setConfluentSchemaRegistryUrl(String schemaRegistry)

setConfluentSchemaRegistrySubject

public abstract KafkaReadSchemaTransformConfiguration.Builder setConfluentSchemaRegistrySubject(String subject)

setSchema

public abstract KafkaReadSchemaTransformConfiguration.Builder setSchema(String schema)

setFileDescriptorPath

public abstract KafkaReadSchemaTransformConfiguration.Builder setFileDescriptorPath(String fileDescriptorPath)

setMessageName

public abstract KafkaReadSchemaTransformConfiguration.Builder setMessageName(String messageName)

setFormat

public abstract KafkaReadSchemaTransformConfiguration.Builder setFormat(String format)

setAutoOffsetResetConfig

public abstract KafkaReadSchemaTransformConfiguration.Builder setAutoOffsetResetConfig(String startOffset)

setConsumerConfigUpdates

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

setTopic

public abstract KafkaReadSchemaTransformConfiguration.Builder setTopic(String value)

Sets the topic from which to read.

setMaxReadTimeSeconds

public abstract KafkaReadSchemaTransformConfiguration.Builder setMaxReadTimeSeconds(Integer maxReadTimeSeconds)

setErrorHandling

public abstract KafkaReadSchemaTransformConfiguration.Builder setErrorHandling(ErrorHandling errorHandling)

setRedistributed

public abstract KafkaReadSchemaTransformConfiguration.Builder setRedistributed(Boolean redistribute)

setAllowDuplicates

public abstract KafkaReadSchemaTransformConfiguration.Builder setAllowDuplicates(Boolean allowDuplicates)

setRedistributeNumKeys

public abstract KafkaReadSchemaTransformConfiguration.Builder setRedistributeNumKeys(Integer redistributeNumKeys)

setOffsetDeduplication

public abstract KafkaReadSchemaTransformConfiguration.Builder setOffsetDeduplication(Boolean offsetDeduplication)

setRedistributeByRecordKey

public abstract KafkaReadSchemaTransformConfiguration.Builder setRedistributeByRecordKey(Boolean redistributeByRecordKey)

build

public abstract KafkaReadSchemaTransformConfiguration build()

Builds a KafkaReadSchemaTransformConfiguration instance.