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