public class ConsumerConfiguration extends Object
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
logger |
Constructor and Description |
---|
ConsumerConfiguration() |
ConsumerConfiguration(String pipelineName,
String spaceName,
String kafka) |
Modifier and Type | Method and Description |
---|---|
String |
getAuditorClass() |
String |
getCleanserClass() |
String |
getConverterClass() |
String |
getKafkaBootstrapServers() |
String |
getKafkaMessageCommandClass() |
String |
getKafkaMessageValidateClass() |
String |
getKafkaTopic() |
String |
getPipelineName() |
String |
getSpaceName() |
int |
getWebPort() |
String |
toString() |
public int getWebPort()
public String getPipelineName()
public String getSpaceName()
public String getKafkaBootstrapServers()
public String getKafkaTopic()
public String getKafkaMessageCommandClass()
public String getKafkaMessageValidateClass()
public String getConverterClass()
public String getCleanserClass()
public String getAuditorClass()
Copyright © GigaSpaces.