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 ConsumerRecordFilter Used to filter incoming messages from a Kafka topic.ConsumerRecordFilterMetadata The return value for aConsumerRecordFilter.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 FilterResult IdStatus MembershipState -
Exception Summary Exception Description KafkaDeploymentException Thrown if an error occurs connecting to Kafka, establishing the connector grid, or other exception occurs