Package 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 Object
Parameters class to expose the Read transform to an external SDK.

  • Constructor Details

    • Configuration

      public Configuration()

  • Method Details

    • setConsumerConfig

      public void setConsumerConfig(Map<String,String> consumerConfig)

    • setTopics

      public void setTopics(List<String> topics)

    • setKeyDeserializer

      public void setKeyDeserializer(String keyDeserializer)

    • setValueDeserializer

      public void setValueDeserializer(String valueDeserializer)

    • setStartReadTime

      public void setStartReadTime(Long startReadTime)

    • setStopReadTime

      public void setStopReadTime(Long stopReadTime)

    • setMaxNumRecords

      public void setMaxNumRecords(Long maxNumRecords)

    • setMaxReadTime

      public void setMaxReadTime(Long maxReadTime)

    • setCommitOffsetInFinalize

      public void setCommitOffsetInFinalize(Boolean commitOffsetInFinalize)

    • setTimestampPolicy

      public void setTimestampPolicy(String timestampPolicy)

    • setConsumerPollingTimeout

      public void setConsumerPollingTimeout(Long consumerPollingTimeout)

    • setRedistributeNumKeys

      public void setRedistributeNumKeys(Integer redistributeNumKeys)

    • setRedistribute

      public void setRedistribute(Boolean redistribute)

    • setAllowDuplicates

      public void setAllowDuplicates(Boolean allowDuplicates)

    • setOffsetDeduplication

      public void setOffsetDeduplication(Boolean offsetDeduplication)

    • setRedistributeByRecordKey

      public void setRedistributeByRecordKey(Boolean redistributeByRecordKey)

    • setDynamicReadPollIntervalSeconds

      public void setDynamicReadPollIntervalSeconds(Long dynamicReadPollIntervalSeconds)