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
ConnectorGridMetadata
KafkaConnectorGridStartup
KafkaConnectorMain
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.
ProducerObserver

Enum Summary

Enum	Description
MembershipState

Exception Summary

Exception	Description
KafkaDeploymentException	Thrown if an error occurs connecting to Kafka, establishing the connector grid, or other exception occurs