Package org.openspaces.admin.internal.pipelines

Class ConsumerConfiguration

java.lang.Object

org.openspaces.admin.internal.pipelines.ConsumerConfiguration

public class ConsumerConfiguration
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ConsumerConfiguration()
ConsumerConfiguration(String pipelineName, String spaceName, String kafka)

Method Summary

Modifier and Type	Method	Description
String	getAuditorClass()
String	getCleanserClass()
String	getConverterClass()
String	getKafkaBootstrapServers()
String	getKafkaMessageCommandClass()
String	getKafkaMessageValidateClass()
String	getKafkaTopic()
String	getPipelineName()
String	getSpaceName()
int	getWebPort()
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

ConsumerConfiguration

public ConsumerConfiguration()

ConsumerConfiguration

public ConsumerConfiguration(String pipelineName,
 String spaceName,
 String kafka)

Method Details

toString

public String toString()

Overrides:

toString in class Object

getWebPort

public int getWebPort()

getPipelineName

public String getPipelineName()

getSpaceName

public String getSpaceName()

getKafkaBootstrapServers

public String getKafkaBootstrapServers()

getKafkaTopic

public String getKafkaTopic()

getKafkaMessageCommandClass

public String getKafkaMessageCommandClass()

getKafkaMessageValidateClass

public String getKafkaMessageValidateClass()

getConverterClass

public String getConverterClass()

getCleanserClass

public String getCleanserClass()

getAuditorClass

public String getAuditorClass()