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(ConsumerConfiguration consumerConfiguration, GSMessageExecutor messageExecutor, GSMessageConverter messageConverter, GSMessageCleanser messageCleanser, GSAuditor auditor, boolean populateDeletedObjectsTable, String kafkaConsumerGroup, String consumerId, Callback triggerFullSyncConsumerGracefulShutdown, Semaphore sem)

Method Summary

Modifier and Type	Method and Description
String	getKafkaBootstrapServers()
String	getKafkaConsumerGroup()
Properties	getKafkaProperties()
String	getKafkaTopic()
int	getMessageExecutionRetries()
GSMessageExecutor	getMessageExecutor()
int	getPartitionsCount()
GSKafkaConsumerStatusEnum	getStatus()
int	getTotalOperations()
void	increaseNumberOfOperations(int operations)
boolean	isActive()
void	run()
void	setActive(boolean active)
void	setOffset(String offset)
void	setPopulateDeletedObjectsTable(boolean populateDeletedObjectsTable)
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(ConsumerConfiguration consumerConfiguration,
                             GSMessageExecutor messageExecutor,
                             GSMessageConverter messageConverter,
                             GSMessageCleanser messageCleanser,
                             GSAuditor auditor,
                             boolean populateDeletedObjectsTable,
                             String kafkaConsumerGroup,
                             String consumerId,
                             Callback triggerFullSyncConsumerGracefulShutdown,
                             Semaphore sem)

Method Detail

getMessageExecutor

public GSMessageExecutor getMessageExecutor()

run

public void run()

Specified by:

run in interface Runnable

isActive

public boolean isActive()

setActive

public void setActive(boolean active)

getMessageExecutionRetries

public int getMessageExecutionRetries()

setStatus

public void setStatus(GSKafkaConsumerStatusEnum newStatus)

getStatus

public GSKafkaConsumerStatusEnum getStatus()

increaseNumberOfOperations

public void increaseNumberOfOperations(int operations)

getTotalOperations

public int getTotalOperations()
                       throws IOException

Throws:

IOException

getKafkaBootstrapServers

public String getKafkaBootstrapServers()

getKafkaTopic

public String getKafkaTopic()

getKafkaConsumerGroup

public String getKafkaConsumerGroup()

getKafkaProperties

public Properties getKafkaProperties()

setOffset

public void setOffset(String offset)

getPartitionsCount

public int getPartitionsCount()

setPopulateDeletedObjectsTable

public void setPopulateDeletedObjectsTable(boolean populateDeletedObjectsTable)