Package com.helix.core.stream.kafka

Class KafkaStreamConfig.Builder

java.lang.Object

com.helix.core.stream.kafka.KafkaStreamConfig.Builder

Enclosing class:

KafkaStreamConfig

public static class KafkaStreamConfig.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
KafkaStreamConfig.Builder	autoOffsetReset(String autoOffsetReset)
KafkaStreamConfig.Builder	bootstrapServers(String bootstrapServers)
KafkaStreamConfig	build()
KafkaStreamConfig.Builder	commitMode(CommitMode commitMode)
KafkaStreamConfig.Builder	consumerProperty(String key, Object value)
KafkaStreamConfig.Builder	enableAutoCommit(boolean enableAutoCommit)
KafkaStreamConfig.Builder	groupId(String groupId)
KafkaStreamConfig.Builder	inputTopic(String topic)
KafkaStreamConfig.Builder	inputTopics(Set<String> topics)
KafkaStreamConfig.Builder	lowWatermarkPerPartition(int lowWatermarkPerPartition)
KafkaStreamConfig.Builder	maxInFlightPerPartition(int maxInFlightPerPartition)
KafkaStreamConfig.Builder	maxPollRecords(int maxPollRecords)
KafkaStreamConfig.Builder	outputTopic(String outputTopic)
KafkaStreamConfig.Builder	pollTimeout(Duration pollTimeout)
KafkaStreamConfig.Builder	producerProperty(String key, Object value)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

bootstrapServers

public KafkaStreamConfig.Builder bootstrapServers(String bootstrapServers)

groupId

public KafkaStreamConfig.Builder groupId(String groupId)

inputTopic

public KafkaStreamConfig.Builder inputTopic(String topic)

inputTopics

public KafkaStreamConfig.Builder inputTopics(Set<String> topics)

outputTopic

public KafkaStreamConfig.Builder outputTopic(String outputTopic)

autoOffsetReset

public KafkaStreamConfig.Builder autoOffsetReset(String autoOffsetReset)

enableAutoCommit

public KafkaStreamConfig.Builder enableAutoCommit(boolean enableAutoCommit)

commitMode

public KafkaStreamConfig.Builder commitMode(CommitMode commitMode)

pollTimeout

public KafkaStreamConfig.Builder pollTimeout(Duration pollTimeout)

maxPollRecords

public KafkaStreamConfig.Builder maxPollRecords(int maxPollRecords)

maxInFlightPerPartition

public KafkaStreamConfig.Builder maxInFlightPerPartition(int maxInFlightPerPartition)

lowWatermarkPerPartition

public KafkaStreamConfig.Builder lowWatermarkPerPartition(int lowWatermarkPerPartition)

consumerProperty

public KafkaStreamConfig.Builder consumerProperty(String key,
 Object value)

producerProperty

public KafkaStreamConfig.Builder producerProperty(String key,
 Object value)

build

public KafkaStreamConfig build()