Package | Description |
---|---|
com.gigaspaces.dih.consumer | |
com.gigaspaces.dih.consumer.web |
Modifier and Type | Method and Description |
---|---|
GSKafkaConsumerThread |
GSKafkaConsumerThread.setKafkaProperties(Properties kafkaProperties) |
GSKafkaConsumerThread |
GSKafkaConsumerThread.setMessageExecutor(GSMessageExecutor messageExecutor) |
Constructor and Description |
---|
GSConsumerHandler(String pipelineName,
int port,
GSKafkaConsumerThread runnable) |
Copyright © GigaSpaces.