Package | Description |
---|---|
com.gigaspaces.dih.consumer |
Modifier and Type | Class and Description |
---|---|
class |
GSMessageExecutorImpl |
Modifier and Type | Method and Description |
---|---|
GSMessageExecutor |
GSKafkaConsumerThread.getMessageExecutor() |
Constructor and Description |
---|
GSKafkaConsumerThread(ConsumerConfiguration consumerConfiguration,
GSMessageExecutor messageExecutor,
GSMessageConverter messageConverter,
GSMessageCleanser messageCleanser,
GSAuditor auditor,
boolean populateDeletedObjectsTable,
String kafkaConsumerGroup,
String consumerId,
Callback triggerFullSyncConsumerGracefulShutdown,
Semaphore sem) |
Copyright © GigaSpaces.