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

Class KafkaIO.Write.External.Configuration

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaIO.Write.External.Configuration

Enclosing class:

KafkaIO.Write.External

public static class KafkaIO.Write.External.Configuration
extends Object

Parameters class to expose the Write transform to an external SDK.

Constructor Summary

Constructors

Constructor	Description
Configuration()

Method Summary

Modifier and Type	Method	Description
void	setKeySerializer(String keySerializer)
void	setProducerConfig(Map<String,String> producerConfig)
void	setTopic(String topic)
void	setValueSerializer(String valueSerializer)

Methods inherited from class java.lang.Object

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

Constructor Details

Configuration

public Configuration()

Method Details

setProducerConfig

public void setProducerConfig(Map<String,String> producerConfig)

setTopic

public void setTopic(String topic)

setKeySerializer

public void setKeySerializer(String keySerializer)

setValueSerializer

public void setValueSerializer(String valueSerializer)