org.apache.beam.sdk.io.kafka

Class KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

KafkaWriteSchemaTransformProvider

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
KafkaWriteSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method and Description
static KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder	builder()
abstract java.lang.String	getBootstrapServers()
abstract java.lang.String	getFormat()
abstract java.util.Map<java.lang.String,java.lang.String>	getProducerConfigUpdates()
abstract java.lang.String	getTopic()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaWriteSchemaTransformConfiguration

public KafkaWriteSchemaTransformConfiguration()

Method Detail

getFormat

@SchemaFieldDescription(value="The encoding format for the data stored in Kafka. Valid options are: JSON,AVRO")
public abstract java.lang.String getFormat()

getTopic

public abstract java.lang.String getTopic()

getBootstrapServers

@SchemaFieldDescription(value="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,...")
public abstract java.lang.String getBootstrapServers()

getProducerConfigUpdates

@SchemaFieldDescription(value="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")
 @Nullable
public abstract java.util.Map<java.lang.String,java.lang.String> getProducerConfigUpdates()

builder

public static KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder builder()