KafkaIO.Read.External.Configuration (Apache Beam 2.57.0)

Constructors
Constructor and Description
`Configuration()`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`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`	`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

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

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

public void setKeyDeserializer(java.lang.String keyDeserializer)

public void setValueDeserializer(java.lang.String valueDeserializer)

public void setStartReadTime(java.lang.Long startReadTime)

public void setStopReadTime(java.lang.Long stopReadTime)

public void setMaxNumRecords(java.lang.Long maxNumRecords)

public void setMaxReadTime(java.lang.Long maxReadTime)

public void setCommitOffsetInFinalize(java.lang.Boolean commitOffsetInFinalize)

public void setTimestampPolicy(java.lang.String timestampPolicy)

public void setConsumerPollingTimeout(java.lang.Long consumerPollingTimeout)

Class KafkaIO.Read.External.Configuration