Package | Description |
---|---|
com.gigaspaces.dih.consumer | |
com.gigaspaces.dih.consumer.cr8 |
Modifier and Type | Method and Description |
---|---|
abstract DataPipelineMessage |
GSMessageConverter.toGSMessage(KafkaMessage kafkaMessage,
String streamName) |
Modifier and Type | Class and Description |
---|---|
class |
CR8KafkaCommandMessage |
class |
CR8KafkaMessage |
class |
CR8KafkaValidateMessage |
Modifier and Type | Method and Description |
---|---|
DataPipelineMessage |
CR8MessageConverter.toGSMessage(KafkaMessage kafkaMessage,
String pipelineName) |
Copyright © GigaSpaces.