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	setFormat(java.lang.String format)
abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	setProducerConfigUpdates(java.util.Map<java.lang.String,java.lang.String> producerConfigUpdates)
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)

build

public abstract KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration build()