@DefaultSchema(value=AutoValueSchema.class) public abstract static class KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration extends java.lang.Object implements java.io.Serializable
Modifier and Type | Class and Description |
---|---|
static class |
KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder |
Constructor and Description |
---|
KafkaWriteSchemaTransformConfiguration() |
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() |
public KafkaWriteSchemaTransformConfiguration()
public abstract java.lang.String getFormat()
public abstract java.lang.String getTopic()
public abstract java.lang.String getBootstrapServers()
@Nullable public abstract java.util.Map<java.lang.String,java.lang.String> getProducerConfigUpdates()
public static KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration.Builder builder()