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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

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

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

setFormat

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

setTopic

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

setBootstrapServers

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

setProducerConfigUpdates

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

setErrorHandling

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

setFileDescriptorPath

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

setMessageName

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

setSchema

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

build

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration build()