Package com.espertech.esperio.kafka

Class EsperIOKafkaInputAdapter

java.lang.Object
com.espertech.esperio.kafka.EsperIOKafkaInputAdapter
public class EsperIOKafkaInputAdapter extends Object

  • Constructor Details

    • EsperIOKafkaInputAdapter

      public EsperIOKafkaInputAdapter(Properties properties, String runtimeURI)

  • Method Details

    • start

      public void start()

    • destroy

      public void destroy()

    • getRequiredProperty

      protected static String getRequiredProperty(Properties properties, String config)