org.openspaces.admin.di

Class ConsumerConfiguration

java.lang.Object

org.openspaces.admin.di.ConsumerConfiguration

public class ConsumerConfiguration
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ConsumerConfiguration()

Method Summary

Modifier and Type	Method and Description
static ConsumerConfiguration	fromJson(String json)
Cdc	getCdc()
ConflictResolution	getConflictResolution()
Generic	getGeneric()
KafkaConfiguration	getKafka()
ParserExceptionPolicy	getParserExceptionPolicy()
SpaceConfiguration	getSpace()
List<Table>	getTables()
void	setCdc(Cdc cdc)
void	setConflictResolution(ConflictResolution conflictResolution)
void	setGeneric(Generic generic)
void	setKafka(KafkaConfiguration kafka)
void	setParserExceptionPolicy(ParserExceptionPolicy parserExceptionPolicy)
void	setSpace(SpaceConfiguration space)
void	setTables(List<Table> tables)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static org.slf4j.Logger logger

Constructor Detail

ConsumerConfiguration

public ConsumerConfiguration()

Method Detail

getCdc

public Cdc getCdc()

getGeneric

public Generic getGeneric()

getKafka

public KafkaConfiguration getKafka()

getSpace

public SpaceConfiguration getSpace()

getConflictResolution

public ConflictResolution getConflictResolution()

setConflictResolution

public void setConflictResolution(ConflictResolution conflictResolution)

getTables

public List<Table> getTables()

setTables

public void setTables(List<Table> tables)

setGeneric

public void setGeneric(Generic generic)

setCdc

public void setCdc(Cdc cdc)

setKafka

public void setKafka(KafkaConfiguration kafka)

setSpace

public void setSpace(SpaceConfiguration space)

toString

public String toString()

Overrides:

toString in class Object

fromJson

public static ConsumerConfiguration fromJson(String json)
                                      throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

getParserExceptionPolicy

public ParserExceptionPolicy getParserExceptionPolicy()

setParserExceptionPolicy

public void setParserExceptionPolicy(ParserExceptionPolicy parserExceptionPolicy)