Package com.scaleoutsoftware.digitaltwin.datasource.kafka

Class KafkaEndpoint

  • public class KafkaEndpoint
extends java.lang.Object
    Creates a KafkaEndpoint which can be used to consume and produce messages from and to Kafka.

    • Method Summary

      Modifier and Type Method Description
      void teardown()
      Tears down the KafkaEndpoint which disables all consuming and producing from Kafka

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • teardown

        public void teardown()
              throws KafkaDeploymentException
        Tears down the KafkaEndpoint which disables all consuming and producing from Kafka
        Throws:
        KafkaDeploymentException - if an exception occurs while unloading the producer and consumer grids