| 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.