Package org.openspaces.admin.internal.pipelines

Class Configuration

java.lang.Object

org.openspaces.admin.internal.pipelines.Configuration

public class Configuration
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
Configuration()
Configuration(String spaceName, String kafkaMaxPollRecords, String kafkaReceiveBufferConfig, SourceConfiguration sourceConfiguration, KafkaConfiguration kafkaConfiguration, ConnectorConfiguration connectorConfiguration, ConsumerConfiguration consumerConfiguration)

Method Summary

Modifier and Type	Method	Description
ConnectorConfiguration	getConnectorConfiguration()
ConsumerConfiguration	getConsumerConfiguration()
KafkaConfiguration	getKafkaConfiguration()
String	getKafkaMaxPollRecords()
String	getKafkaReceiveBufferConfig()
SourceConfiguration	getSourceConfiguration()
String	getSpaceName()
void	setConnectorConfiguration(ConnectorConfiguration connectorConfiguration)
void	setConsumerConfiguration(ConsumerConfiguration consumerConfiguration)
void	setKafkaConfiguration(KafkaConfiguration kafkaConfiguration)
void	setKafkaMaxPollRecords(String kafkaMaxPollRecords)
void	setKafkaReceiveBufferConfig(String kafkaReceiveBufferConfig)
void	setSourceConfiguration(SourceConfiguration sourceConfiguration)
void	setSpaceName(String spaceName)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

logger

protected static org.slf4j.Logger logger

Constructor Details

Configuration

public Configuration()

Configuration

public Configuration(String spaceName,
 String kafkaMaxPollRecords,
 String kafkaReceiveBufferConfig,
 SourceConfiguration sourceConfiguration,
 KafkaConfiguration kafkaConfiguration,
 ConnectorConfiguration connectorConfiguration,
 ConsumerConfiguration consumerConfiguration)

Method Details

getSpaceName

public String getSpaceName()

setSpaceName

public void setSpaceName(String spaceName)

getSourceConfiguration

public SourceConfiguration getSourceConfiguration()

getKafkaConfiguration

public KafkaConfiguration getKafkaConfiguration()

setSourceConfiguration

public void setSourceConfiguration(SourceConfiguration sourceConfiguration)

setKafkaConfiguration

public void setKafkaConfiguration(KafkaConfiguration kafkaConfiguration)

getConnectorConfiguration

public ConnectorConfiguration getConnectorConfiguration()

setConnectorConfiguration

public void setConnectorConfiguration(ConnectorConfiguration connectorConfiguration)

getConsumerConfiguration

public ConsumerConfiguration getConsumerConfiguration()

setConsumerConfiguration

public void setConsumerConfiguration(ConsumerConfiguration consumerConfiguration)

getKafkaMaxPollRecords

public String getKafkaMaxPollRecords()

setKafkaMaxPollRecords

public void setKafkaMaxPollRecords(String kafkaMaxPollRecords)

getKafkaReceiveBufferConfig

public String getKafkaReceiveBufferConfig()

setKafkaReceiveBufferConfig

public void setKafkaReceiveBufferConfig(String kafkaReceiveBufferConfig)

toString

public String toString()

Overrides:

toString in class Object