public class EsperIOKafkaInputAdapter extends Object
Constructor and Description |
---|
EsperIOKafkaInputAdapter(Properties properties,
String engineURI) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
protected static String |
getRequiredProperty(Properties properties,
String config) |
void |
start() |
public EsperIOKafkaInputAdapter(Properties properties, String engineURI)
public void start()
public void destroy()
protected static String getRequiredProperty(Properties properties, String config)