Uses of Class
com.helix.core.stream.kafka.KafkaStreamConfig.Builder

Packages that use KafkaStreamConfig.Builder

Package	Description
com.helix.core.stream.kafka

Uses of KafkaStreamConfig.Builder in com.helix.core.stream.kafka

Methods in com.helix.core.stream.kafka that return KafkaStreamConfig.Builder

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