Package com.helix.core.stream.kafka

Class KafkaStreamConfig

java.lang.Object

com.helix.core.stream.kafka.KafkaStreamConfig

public class KafkaStreamConfig
extends Object

Configuration for clustered Kafka rule streaming ingestion and result publishing.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaStreamConfig.Builder

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_AUTO_OFFSET_RESET
static final String	DEFAULT_BOOTSTRAP_SERVERS
static final String	DEFAULT_GROUP_ID
static final int	DEFAULT_LOW_WATERMARK_PER_PARTITION
static final int	DEFAULT_MAX_IN_FLIGHT_PER_PARTITION
static final int	DEFAULT_MAX_POLL_RECORDS
static final Duration	DEFAULT_POLL_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
KafkaStreamConfig(String bootstrapServers, String groupId, Set<String> inputTopics, String outputTopic, String autoOffsetReset, boolean enableAutoCommit, CommitMode commitMode, Duration pollTimeout, int maxPollRecords, int maxInFlightPerPartition, int lowWatermarkPerPartition, Map<String,Object> customConsumerProps, Map<String,Object> customProducerProps)

Method Summary

Modifier and Type	Method	Description
static KafkaStreamConfig.Builder	builder()
static KafkaStreamConfig	defaultConfig()
String	getAutoOffsetReset()
String	getBootstrapServers()
CommitMode	getCommitMode()
Map<String,Object>	getCustomConsumerProps()
Map<String,Object>	getCustomProducerProps()
String	getGroupId()
Set<String>	getInputTopics()
int	getLowWatermarkPerPartition()
int	getMaxInFlightPerPartition()
int	getMaxPollRecords()
String	getOutputTopic()
Duration	getPollTimeout()
boolean	isEnableAutoCommit()
Properties	toConsumerProperties()
Properties	toProducerProperties()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_BOOTSTRAP_SERVERS

public static final String DEFAULT_BOOTSTRAP_SERVERS

See Also:

• Constant Field Values

DEFAULT_GROUP_ID

public static final String DEFAULT_GROUP_ID

See Also:

• Constant Field Values

DEFAULT_AUTO_OFFSET_RESET

public static final String DEFAULT_AUTO_OFFSET_RESET

See Also:

• Constant Field Values

DEFAULT_POLL_TIMEOUT

public static final Duration DEFAULT_POLL_TIMEOUT

DEFAULT_MAX_POLL_RECORDS

public static final int DEFAULT_MAX_POLL_RECORDS

See Also:

• Constant Field Values

DEFAULT_MAX_IN_FLIGHT_PER_PARTITION

public static final int DEFAULT_MAX_IN_FLIGHT_PER_PARTITION

See Also:

• Constant Field Values

DEFAULT_LOW_WATERMARK_PER_PARTITION

public static final int DEFAULT_LOW_WATERMARK_PER_PARTITION

See Also:

• Constant Field Values

Constructor Details

KafkaStreamConfig

public KafkaStreamConfig(String bootstrapServers,
 String groupId,
 Set<String> inputTopics,
 String outputTopic,
 String autoOffsetReset,
 boolean enableAutoCommit,
 CommitMode commitMode,
 Duration pollTimeout,
 int maxPollRecords,
 int maxInFlightPerPartition,
 int lowWatermarkPerPartition,
 Map<String,Object> customConsumerProps,
 Map<String,Object> customProducerProps)

Method Details

builder

public static KafkaStreamConfig.Builder builder()

defaultConfig

public static KafkaStreamConfig defaultConfig()

toConsumerProperties

public Properties toConsumerProperties()

toProducerProperties

public Properties toProducerProperties()

getBootstrapServers

public String getBootstrapServers()

getGroupId

public String getGroupId()

getInputTopics

public Set<String> getInputTopics()

getOutputTopic

public String getOutputTopic()

getAutoOffsetReset

public String getAutoOffsetReset()

isEnableAutoCommit

public boolean isEnableAutoCommit()

getCommitMode

public CommitMode getCommitMode()

getPollTimeout

public Duration getPollTimeout()

getMaxPollRecords

public int getMaxPollRecords()

getMaxInFlightPerPartition

public int getMaxInFlightPerPartition()

getLowWatermarkPerPartition

public int getLowWatermarkPerPartition()

getCustomConsumerProps

public Map<String,Object> getCustomConsumerProps()

getCustomProducerProps

public Map<String,Object> getCustomProducerProps()