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 java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
Configuration()

Method Summary

Modifier and Type	Method and Description
void	setKeySerializer(byte[] keySerializer)
void	setProducerConfig(java.lang.Iterable<KV<byte[],byte[]>> producerConfig)
void	setTopic(byte[] topic)
void	setValueSerializer(byte[] valueSerializer)

Methods inherited from class java.lang.Object

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

Constructor Detail

Configuration

public Configuration()

Method Detail

setProducerConfig

public void setProducerConfig(java.lang.Iterable<KV<byte[],byte[]>> producerConfig)

setTopic

public void setTopic(byte[] topic)

setKeySerializer

public void setKeySerializer(byte[] keySerializer)

setValueSerializer

public void setValueSerializer(byte[] valueSerializer)