Package org.apache.beam.sdk.io.kafka

Class KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder

Enclosing class:

KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration

public abstract static class KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration	build()
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	setBootstrapServers(String bootstrapServers)
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	setErrorHandling(ErrorHandling errorHandling)
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	setFileDescriptorPath(String fileDescriptorPath)
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	setFormat(String format)
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	setMessageName(String messageName)
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	setProducerConfigUpdates(Map<String,String> producerConfigUpdates)
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	setSchema(String schema)
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	setTopic(String topic)

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

setFormat

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder setFormat(String format)

setTopic

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder setTopic(String topic)

setBootstrapServers

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder setBootstrapServers(String bootstrapServers)

setProducerConfigUpdates

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder setProducerConfigUpdates(Map<String,String> producerConfigUpdates)

setErrorHandling

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder setErrorHandling(ErrorHandling errorHandling)

setFileDescriptorPath

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder setFileDescriptorPath(String fileDescriptorPath)

setMessageName

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder setMessageName(String messageName)

setSchema

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder setSchema(String schema)

build

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration build()