org.apache.beam.sdk.io.kafka

Class KafkaSchemaTransformReadConfiguration.Builder

java.lang.Object

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

Enclosing class:

KafkaSchemaTransformReadConfiguration

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

Builder for the KafkaSchemaTransformReadConfiguration.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract KafkaSchemaTransformReadConfiguration	build() Builds a KafkaSchemaTransformReadConfiguration instance.
abstract KafkaSchemaTransformReadConfiguration.Builder	setAutoOffsetResetConfig(java.lang.String startOffset)
abstract KafkaSchemaTransformReadConfiguration.Builder	setAvroSchema(java.lang.String schema)
abstract KafkaSchemaTransformReadConfiguration.Builder	setBootstrapServers(java.lang.String value) Sets the bootstrap servers for the Kafka consumer.
abstract KafkaSchemaTransformReadConfiguration.Builder	setConfluentSchemaRegistrySubject(java.lang.String subject)
abstract KafkaSchemaTransformReadConfiguration.Builder	setConfluentSchemaRegistryUrl(java.lang.String schemaRegistry)
abstract KafkaSchemaTransformReadConfiguration.Builder	setConsumerConfigUpdates(java.util.Map<java.lang.String,java.lang.String> consumerConfigUpdates)
abstract KafkaSchemaTransformReadConfiguration.Builder	setDataFormat(java.lang.String dataFormat)
abstract KafkaSchemaTransformReadConfiguration.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 KafkaSchemaTransformReadConfiguration.Builder setBootstrapServers(java.lang.String value)

Sets the bootstrap servers for the Kafka consumer.

setConfluentSchemaRegistryUrl

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

setConfluentSchemaRegistrySubject

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

setAvroSchema

public abstract KafkaSchemaTransformReadConfiguration.Builder setAvroSchema(java.lang.String schema)

setDataFormat

public abstract KafkaSchemaTransformReadConfiguration.Builder setDataFormat(java.lang.String dataFormat)

setAutoOffsetResetConfig

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

setConsumerConfigUpdates

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

setTopic

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

Sets the topic from which to read.

build

public abstract KafkaSchemaTransformReadConfiguration build()

Builds a KafkaSchemaTransformReadConfiguration instance.