Package com.gigaspaces.dih.consumer.web

Class GSConsumerHandler

java.lang.Object

com.gigaspaces.dih.consumer.web.GSConsumerHandler

public class GSConsumerHandler
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NO_THREADS_STATUS_MESSAGE

Constructor Summary

Constructors

Constructor	Description
GSConsumerHandler(String consumerName, int port)

Method Summary

Modifier and Type	Method	Description
void	clearPipelineTables(List<String> typesList)
String	delete()
void	deletePipelineCdcInfo(String pipelineName)
void	deleteTopic(String topic)
void	destroy()
long	getActiveThreadsCount()	UNHEALTHY - retrying PENDING - deployed but haven't started yet ACTIVE - started
ConsumerConfiguration	getConsumerConfigFromZK()
GSKafkaConsumerStatusEnum	getConsumerStatus()	Lazy status check, when there are no consumer we return the last status that was saved which can be either STOPPED or PENDING
String	getKafkaBootstrap()
String	getKafkaBootstrapServers()
String	getKafkaTopic()
Integer	getPartitions()
ArrayList<String>	getRegisteredTypes()
short	getReplicationFactor()
int	getStatusCode()
String	getThreadsStatus()
int	getTotalOperation()
boolean	hasKafkaDeltaInTopic()
void	init(GigaSpace gigaSpace, String puName, ConsumerConfiguration consumerConfigFromZK)
GSMessageCleanser	initCleanser()
GSMessageExecutorImpl	initExecutor()
boolean	isAlive()
boolean	isTopicExists(String topic)
void	saveConsumerConfigToZK(ConsumerConfiguration consumerConfiguration)
void	setConsumerConfiguration(ConsumerConfiguration consumerConfiguration)
void	setConsumerStatus(GSKafkaConsumerStatusEnum newStatus)
void	setPartitionsAndPersistToZK(int partitions)
void	startDataIngestion(String offset, Integer partitionsCount)
void	startPopulationOfDeletedTables()
void	stopDataIngestion()
void	stopPopulationOfDeletedTables()

Methods inherited from class java.lang.Object

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

Field Details

NO_THREADS_STATUS_MESSAGE

public static final String NO_THREADS_STATUS_MESSAGE

See Also:

• Constant Field Values

Constructor Details

GSConsumerHandler

public GSConsumerHandler(String consumerName,
 int port)

Method Details

init

public void init(GigaSpace gigaSpace,
 String puName,
 ConsumerConfiguration consumerConfigFromZK)
          throws IOException

Throws:

IOException

initExecutor

public GSMessageExecutorImpl initExecutor()

initCleanser

public GSMessageCleanser initCleanser()

startDataIngestion

public void startDataIngestion(String offset,
 Integer partitionsCount)
                        throws Exception

Throws:

Exception

getConsumerConfigFromZK

public ConsumerConfiguration getConsumerConfigFromZK()
                                              throws Exception

Throws:

Exception

saveConsumerConfigToZK

public void saveConsumerConfigToZK(ConsumerConfiguration consumerConfiguration)
                            throws IOException

Throws:

IOException

stopDataIngestion

public void stopDataIngestion()

isAlive

public boolean isAlive()

getStatusCode

public int getStatusCode()

hasKafkaDeltaInTopic

public boolean hasKafkaDeltaInTopic()
                             throws ExecutionException,
InterruptedException,
TimeoutException

Throws:

ExecutionException

InterruptedException

TimeoutException

setConsumerStatus

public void setConsumerStatus(GSKafkaConsumerStatusEnum newStatus)

getConsumerStatus

public GSKafkaConsumerStatusEnum getConsumerStatus()

Lazy status check, when there are no consumer we return the last status that was saved which can be either STOPPED or PENDING

getTotalOperation

public int getTotalOperation()
                      throws IOException

Throws:

IOException

delete

public String delete()

getRegisteredTypes

public ArrayList<String> getRegisteredTypes()

getKafkaBootstrap

public String getKafkaBootstrap()

deletePipelineCdcInfo

public void deletePipelineCdcInfo(String pipelineName)
                           throws ExecutionException

Throws:

ExecutionException

setConsumerConfiguration

public void setConsumerConfiguration(ConsumerConfiguration consumerConfiguration)

clearPipelineTables

public void clearPipelineTables(List<String> typesList)
                         throws ExecutionException

Throws:

ExecutionException

destroy

public void destroy()

startPopulationOfDeletedTables

public void startPopulationOfDeletedTables()

stopPopulationOfDeletedTables

public void stopPopulationOfDeletedTables()

setPartitionsAndPersistToZK

public void setPartitionsAndPersistToZK(int partitions)
                                 throws Exception

Throws:

Exception

getPartitions

public Integer getPartitions()

getActiveThreadsCount

public long getActiveThreadsCount()

UNHEALTHY - retrying PENDING - deployed but haven't started yet ACTIVE - started

getThreadsStatus

public String getThreadsStatus()

isTopicExists

public boolean isTopicExists(String topic)
                      throws ExecutionException,
InterruptedException,
TimeoutException

Throws:

ExecutionException

InterruptedException

TimeoutException

deleteTopic

public void deleteTopic(String topic)
                 throws Exception

Throws:

Exception

getKafkaBootstrapServers

public String getKafkaBootstrapServers()

getKafkaTopic

public String getKafkaTopic()

getReplicationFactor

public short getReplicationFactor()