Package com.scaleoutsoftware.digitaltwin.hosting.kafka

Interface DigitalTwinKafkaConnection

  • public interface DigitalTwinKafkaConnection
    Abstraction to send a message to a Kafka Broker through a Digital Twin connector.

    • Method Summary

      Modifier and Type Method Description
      void publishToTopicAsync​(java.lang.String topic, java.lang.String id, byte[] message)
      Publish a message to a Kafka broker configured through a Digital Twin connector.

    • Method Detail

      • publishToTopicAsync

        void publishToTopicAsync​(java.lang.String topic,
                         java.lang.String id,
                         byte[] message)
        Publish a message to a Kafka broker configured through a Digital Twin connector.
        Parameters:
        topic - the topic to publish the message to.
        id - the ID of the message.
        message - the message to publish.