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

Class KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration

java.lang.Object

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

All Implemented Interfaces:

Serializable

Enclosing class:

KafkaWriteSchemaTransformProvider

@DefaultSchema(AutoValueSchema.class)
public abstract static class KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
KafkaWriteSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method	Description
static KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	builder()
abstract String	getBootstrapServers()
abstract ErrorHandling	getErrorHandling()
abstract String	getFileDescriptorPath()
abstract String	getFormat()
abstract String	getMessageName()
abstract Map<String,String>	getProducerConfigUpdates()
abstract String	getSchema()
abstract String	getTopic()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaWriteSchemaTransformConfiguration

public KafkaWriteSchemaTransformConfiguration()

Method Details

getFormat

@SchemaFieldDescription("The encoding format for the data stored in Kafka. Valid options are: RAW,JSON,AVRO,PROTO")
@SchemaFieldNumber("0")
public abstract String getFormat()

getTopic

@SchemaFieldNumber("1")
public abstract String getTopic()

getBootstrapServers

@SchemaFieldDescription("A list of host/port pairs to use for establishing the initial connection to the Kafka cluster. The client will make use of all servers irrespective of which servers are specified here for bootstrapping\u2014this list only impacts the initial hosts used to discover the full set of servers. | Format: host1:port1,host2:port2,...")
@SchemaFieldNumber("2")
public abstract String getBootstrapServers()

getProducerConfigUpdates

@SchemaFieldDescription("A list of key-value pairs that act as configuration parameters for Kafka producers. Most of these configurations will not be needed, but if you need to customize your Kafka producer, you may use this. See a detailed list: https://docs.confluent.io/platform/current/installation/configuration/producer-configs.html")
@SchemaFieldNumber("3")
@Nullable
public abstract Map<String,String> getProducerConfigUpdates()

getErrorHandling

@SchemaFieldDescription("This option specifies whether and where to output unwritable rows.")
@SchemaFieldNumber("4")
@Nullable
public abstract ErrorHandling getErrorHandling()

getFileDescriptorPath

@SchemaFieldDescription("The path to the Protocol Buffer File Descriptor Set file. This file is used for schema definition and message serialization.")
@SchemaFieldNumber("5")
@Nullable
public abstract String getFileDescriptorPath()

getMessageName

@SchemaFieldDescription("The name of the Protocol Buffer message to be used for schema extraction and data conversion.")
@SchemaFieldNumber("6")
@Nullable
public abstract String getMessageName()

getSchema

@SchemaFieldNumber("7")
@Nullable
public abstract String getSchema()

builder

public static KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder builder()