org.apache.beam.sdk.io.kafka

Class KafkaIO.Read.External.Configuration

java.lang.Object

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

Enclosing class:

KafkaIO.Read.External

public static class KafkaIO.Read.External.Configuration
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
Configuration()

Method Summary

Modifier and Type	Method and Description
void	setAllowDuplicates(java.lang.Boolean allowDuplicates)
void	setCommitOffsetInFinalize(java.lang.Boolean commitOffsetInFinalize)
void	setConsumerConfig(java.util.Map<java.lang.String,java.lang.String> consumerConfig)
void	setConsumerPollingTimeout(java.lang.Long consumerPollingTimeout)
void	setKeyDeserializer(java.lang.String keyDeserializer)
void	setMaxNumRecords(java.lang.Long maxNumRecords)
void	setMaxReadTime(java.lang.Long maxReadTime)
void	setRedistribute(java.lang.Boolean redistribute)
void	setRedistributeNumKeys(java.lang.Integer redistributeNumKeys)
void	setStartReadTime(java.lang.Long startReadTime)
void	setStopReadTime(java.lang.Long stopReadTime)
void	setTimestampPolicy(java.lang.String timestampPolicy)
void	setTopics(java.util.List<java.lang.String> topics)
void	setValueDeserializer(java.lang.String valueDeserializer)

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

setConsumerConfig

public void setConsumerConfig(java.util.Map<java.lang.String,java.lang.String> consumerConfig)

setTopics

public void setTopics(java.util.List<java.lang.String> topics)

setKeyDeserializer

public void setKeyDeserializer(java.lang.String keyDeserializer)

setValueDeserializer

public void setValueDeserializer(java.lang.String valueDeserializer)

setStartReadTime

public void setStartReadTime(java.lang.Long startReadTime)

setStopReadTime

public void setStopReadTime(java.lang.Long stopReadTime)

setMaxNumRecords

public void setMaxNumRecords(java.lang.Long maxNumRecords)

setMaxReadTime

public void setMaxReadTime(java.lang.Long maxReadTime)

setCommitOffsetInFinalize

public void setCommitOffsetInFinalize(java.lang.Boolean commitOffsetInFinalize)

setTimestampPolicy

public void setTimestampPolicy(java.lang.String timestampPolicy)

setConsumerPollingTimeout

public void setConsumerPollingTimeout(java.lang.Long consumerPollingTimeout)

setRedistributeNumKeys

public void setRedistributeNumKeys(java.lang.Integer redistributeNumKeys)

setRedistribute

public void setRedistribute(java.lang.Boolean redistribute)

setAllowDuplicates

public void setAllowDuplicates(java.lang.Boolean allowDuplicates)