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:

  • 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") public abstract String getFormat()

    • getTopic

      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,...") 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") @Nullable public abstract Map<String,String> getProducerConfigUpdates()

    • getErrorHandling

      @SchemaFieldDescription("This option specifies whether and where to output unwritable rows.") @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.") @Nullable public abstract String getFileDescriptorPath()

    • getMessageName

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

    • getSchema

      @Nullable public abstract String getSchema()

    • builder

      public static KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder builder()