public static class KafkaIO.Read.External.Configuration
extends java.lang.Object
Constructor and Description |
---|
Configuration() |
Modifier and Type | Method and Description |
---|---|
void |
setConsumerConfig(java.lang.Iterable<KV<java.lang.String,java.lang.String>> consumerConfig) |
void |
setKeyDeserializer(java.lang.String keyDeserializer) |
void |
setTopics(java.lang.Iterable<java.lang.String> topics) |
void |
setValueDeserializer(java.lang.String valueDeserializer) |
public void setConsumerConfig(java.lang.Iterable<KV<java.lang.String,java.lang.String>> consumerConfig)
public void setTopics(java.lang.Iterable<java.lang.String> topics)
public void setKeyDeserializer(java.lang.String keyDeserializer)
public void setValueDeserializer(java.lang.String valueDeserializer)