Uses of Interface
com.gigaspaces.dih.consumer.cr8.KafkaMessage

Packages that use KafkaMessage

Package	Description
com.gigaspaces.dih.consumer
com.gigaspaces.dih.consumer.cr8

Uses of KafkaMessage in com.gigaspaces.dih.consumer

Methods in com.gigaspaces.dih.consumer with parameters of type KafkaMessage

Modifier and Type	Method and Description
abstract DataPipelineMessage	GSMessageConverter.toGSMessage(KafkaMessage kafkaMessage, String streamName)

Uses of KafkaMessage in com.gigaspaces.dih.consumer.cr8

Classes in com.gigaspaces.dih.consumer.cr8 that implement KafkaMessage

Modifier and Type	Class and Description
class	CR8KafkaCommandMessage
class	CR8KafkaFullSyncIndicatorMessage
class	CR8KafkaIndicatorMessage
class	CR8KafkaMessage
class	CR8KafkaValidateMessage

Methods in com.gigaspaces.dih.consumer.cr8 with parameters of type KafkaMessage

Modifier and Type	Method and Description
DataPipelineMessage	CR8MessageConverter.toGSMessage(KafkaMessage kafkaMessage, String pipelineName)