com.gigaspaces.dih.consumer

Class GSKafkaConsumerThread

java.lang.Object

com.gigaspaces.dih.consumer.GSKafkaConsumerThread

All Implemented Interfaces:

Runnable

public class GSKafkaConsumerThread
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore	zookeeperAttributeStore

Constructor Summary

Constructors

Constructor and Description
GSKafkaConsumerThread(String pipelineName, String targetSpaceName, String kafkaBootstrapServers, String kafkaTopic, String kafkaMessageCommandClass, String kafkaMessageValidationClass, GSMessageConverter messageConverter, GSMessageCleanser messageCleanser, GSAuditor auditor)

Method Summary

Modifier and Type	Method and Description
void	createTopic(Properties props, String topic, int partitions, int replication)
GSAuditor	getAuditor()
String	getKafkaBootstrapServers()
String	getKafkaConsumerGroup()
Properties	getKafkaProperties()
String	getKafkaTopic()
GSMessageCleanser	getMessageCleanser()
int	getMessageExecutionRetries()
GSMessageExecutor	getMessageExecutor()
ArrayList<String>	getRegisteredTypes()
GSKafkaConsumerStatusEnum	getStatus()
String	getTargetSpaceName()
int	getTotalOperations()
void	increaseNumberOfOperation()
boolean	isActive()
void	run()
void	setActive(boolean active)
GSKafkaConsumerThread	setKafkaProperties(Properties kafkaProperties)
GSKafkaConsumerThread	setMessageExecutor(GSMessageExecutor messageExecutor)
void	setStatus(GSKafkaConsumerStatusEnum newStatus)

Methods inherited from class java.lang.Object

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

Field Detail

zookeeperAttributeStore

public org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore zookeeperAttributeStore

Constructor Detail

GSKafkaConsumerThread

public GSKafkaConsumerThread(String pipelineName,
                             String targetSpaceName,
                             String kafkaBootstrapServers,
                             String kafkaTopic,
                             String kafkaMessageCommandClass,
                             String kafkaMessageValidationClass,
                             GSMessageConverter messageConverter,
                             GSMessageCleanser messageCleanser,
                             GSAuditor auditor)

Method Detail

createTopic

public void createTopic(Properties props,
                        String topic,
                        int partitions,
                        int replication)
                 throws ExecutionException,
                        InterruptedException,
                        TimeoutException

Throws:

ExecutionException

InterruptedException

TimeoutException

setKafkaProperties

public GSKafkaConsumerThread setKafkaProperties(Properties kafkaProperties)

setMessageExecutor

public GSKafkaConsumerThread setMessageExecutor(GSMessageExecutor messageExecutor)

getMessageExecutor

public GSMessageExecutor getMessageExecutor()

run

public void run()

Specified by:

run in interface Runnable

isActive

public boolean isActive()

setActive

public void setActive(boolean active)

getTargetSpaceName

public String getTargetSpaceName()

getKafkaProperties

public Properties getKafkaProperties()

getMessageCleanser

public GSMessageCleanser getMessageCleanser()

getAuditor

public GSAuditor getAuditor()

getMessageExecutionRetries

public int getMessageExecutionRetries()

setStatus

public void setStatus(GSKafkaConsumerStatusEnum newStatus)

getStatus

public GSKafkaConsumerStatusEnum getStatus()
                                    throws IOException

Throws:

IOException

increaseNumberOfOperation

public void increaseNumberOfOperation()

getTotalOperations

public int getTotalOperations()
                       throws IOException

Throws:

IOException

getRegisteredTypes

public ArrayList<String> getRegisteredTypes()

getKafkaBootstrapServers

public String getKafkaBootstrapServers()

getKafkaTopic

public String getKafkaTopic()

getKafkaConsumerGroup

public String getKafkaConsumerGroup()