Package org.apache.beam.sdk.io.kafka
Class KafkaReadSchemaTransformConfiguration.Builder
java.lang.Object
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformConfiguration.Builder
- Enclosing class:
KafkaReadSchemaTransformConfiguration
Builder for the
KafkaReadSchemaTransformConfiguration
.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbuild()
Builds aKafkaReadSchemaTransformConfiguration
instance.setAutoOffsetResetConfig
(String startOffset) setBootstrapServers
(String value) Sets the bootstrap servers for the Kafka consumer.setConfluentSchemaRegistrySubject
(String subject) setConfluentSchemaRegistryUrl
(String schemaRegistry) setConsumerConfigUpdates
(Map<String, String> consumerConfigUpdates) setErrorHandling
(ErrorHandling errorHandling) setFileDescriptorPath
(String fileDescriptorPath) setMaxReadTimeSeconds
(Integer maxReadTimeSeconds) setMessageName
(String messageName) Sets the topic from which to read.
-
Constructor Details
-
Builder
public Builder()
-
-
Method Details
-
setBootstrapServers
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
-
setFileDescriptorPath
public abstract KafkaReadSchemaTransformConfiguration.Builder setFileDescriptorPath(String fileDescriptorPath) -
setMessageName
-
setFormat
-
setAutoOffsetResetConfig
public abstract KafkaReadSchemaTransformConfiguration.Builder setAutoOffsetResetConfig(String startOffset) -
setConsumerConfigUpdates
public abstract KafkaReadSchemaTransformConfiguration.Builder setConsumerConfigUpdates(Map<String, String> consumerConfigUpdates) -
setTopic
Sets the topic from which to read. -
setMaxReadTimeSeconds
public abstract KafkaReadSchemaTransformConfiguration.Builder setMaxReadTimeSeconds(Integer maxReadTimeSeconds) -
setErrorHandling
public abstract KafkaReadSchemaTransformConfiguration.Builder setErrorHandling(ErrorHandling errorHandling) -
build
Builds aKafkaReadSchemaTransformConfiguration
instance.
-