Package com.scaleoutsoftware.digitaltwin.datasource.kafka
Digital twin connector API - KafkaEndpoint used to allow DigitalTwins to send and receive messages using a Kafka deployment
-
Class Summary Class Description KafkaEndpoint Creates a KafkaEndpoint which can be used to consume and produce messages from and to Kafka.KafkaEndpointBuilder The KafkaEndpointBuilder is used to create an endpoint between a Kafka server and the DigitalTwin execution environment.KafkaRecordPosterAsJsonArray The KafkaRecordPosterAsJsonArray concatenates consumed messages for a given DigitalTwin and posts the list of messages to the DigitalTwin. -
Exception Summary Exception Description KafkaDeploymentException Thrown if an error occurs connecting to Kafka, establishing the connector grid, or other exception occurs