com.gigaspaces.dih.consumer.web

Class GSConsumerHandler

java.lang.Object

com.gigaspaces.dih.consumer.web.GSConsumerHandler

public class GSConsumerHandler
extends Object

Constructor Summary

Constructors

Constructor and Description
GSConsumerHandler(String consumerName, int port)

Method Summary

Modifier and Type	Method and Description
void	clearPipelineTables(List<String> typesList)
String	delete()
void	deletePipelineCdcInfo(String pipelineName)
void	deleteTopics(org.apache.kafka.clients.admin.AdminClient adminClient, List<String> topics)
void	destroy()
long	getActiveThreadsCount() UNHEALTHY - retrying PENDING - deployed but haven't started yet ACTIVE - started
ConsumerConfiguration	getConsumerConfigFromZK()
ConsumerConfiguration	getConsumerConfiguration()
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)
GSMessageCleanser	initCleanser()
GSMessageExecutorImpl	initExecutor()
boolean	isAlive()
void	saveConsumerConfigToZK(ConsumerConfiguration consumerConfiguration)
void	setConsumerConfiguration(ConsumerConfiguration consumerConfiguration)
void	setConsumerStatus(GSKafkaConsumerStatusEnum newStatus)
void	setPartitionsAndPersistToZK(int partitions)
void	startDataIngestion(String offset, Integer partitionsCount, Boolean cleanStart)
void	startPopulationOfDeletedTables()
void	stopDataIngestion()
void	stopPopulationOfDeletedTables()

Methods inherited from class java.lang.Object

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

Constructor Detail

GSConsumerHandler

public GSConsumerHandler(String consumerName,
                         int port)

Method Detail

init

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

Throws:

IOException

initExecutor

public GSMessageExecutorImpl initExecutor()

initCleanser

public GSMessageCleanser initCleanser()

startDataIngestion

public void startDataIngestion(String offset,
                               Integer partitionsCount,
                               Boolean cleanStart)
                        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

getConsumerConfiguration

public ConsumerConfiguration getConsumerConfiguration()

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()

deleteTopics

public void deleteTopics(org.apache.kafka.clients.admin.AdminClient adminClient,
                         List<String> topics)
                  throws Exception

Throws:

Exception

getKafkaBootstrapServers

public String getKafkaBootstrapServers()

getKafkaTopic

public String getKafkaTopic()

getReplicationFactor

public short getReplicationFactor()